File tree Expand file tree Collapse file tree 1 file changed +8
-2
lines changed
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/state Expand file tree Collapse file tree 1 file changed +8
-2
lines changed Original file line number Diff line number Diff line change @@ -673,7 +673,10 @@ case class RangeKeyScanStateEncoderSpec(
673673 }
674674}
675675
676- /** The encoder specification for [[TimestampAsPrefixKeyStateEncoder ]]. */
676+ /**
677+ * The encoder specification for [[TimestampAsPrefixKeyStateEncoder ]].
678+ * The encoder expects the provided key schema to have [original key fields..., timestamp field].
679+ */
677680case class TimestampAsPrefixKeyStateEncoderSpec (keySchema : StructType )
678681 extends KeyStateEncoderSpec {
679682
@@ -688,7 +691,10 @@ case class TimestampAsPrefixKeyStateEncoderSpec(keySchema: StructType)
688691 }
689692}
690693
691- /** The encoder specification for [[TimestampAsPostfixKeyStateEncoder ]]. */
694+ /**
695+ * The encoder specification for [[TimestampAsPostfixKeyStateEncoder ]].
696+ * The encoder expects the provided key schema to have [original key fields..., timestamp field].
697+ */
692698case class TimestampAsPostfixKeyStateEncoderSpec (keySchema : StructType )
693699 extends KeyStateEncoderSpec {
694700
You can’t perform that action at this time.
0 commit comments