Skip to content

Commit bda7121

Browse files
committed
clarify further since it required one more hop on confirmation
1 parent e3cdc47 commit bda7121

File tree

1 file changed

+8
-2
lines changed
  • sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/state

1 file changed

+8
-2
lines changed

sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/state/StateStore.scala

Lines changed: 8 additions & 2 deletions
Original file line numberDiff line numberDiff 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+
*/
677680
case 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+
*/
692698
case class TimestampAsPostfixKeyStateEncoderSpec(keySchema: StructType)
693699
extends KeyStateEncoderSpec {
694700

0 commit comments

Comments
 (0)