StateManagerImplV2¶
StateManagerImplV2
is a concrete <
StateManagerImplV2
is <FlatMapGroupsWithStateExecHelper
utility is requested for a <stateFormatVersion
is 2
).
=== [[creating-instance]] Creating StateManagerImplV2 Instance
StateManagerImplV2
takes the following to be created:
- [[stateEncoder]] State encoder (
ExpressionEncoder[Any]
) - [[shouldStoreTimestamp]]
shouldStoreTimestamp
flag
StateManagerImplV2
initializes the <
=== [[stateSchema]] State Schema -- stateSchema
Value
[source, scala]¶
stateSchema: StructType¶
NOTE: stateSchema
is part of the <
stateSchema
...FIXME
=== [[stateSerializerExprs]] State Serializer -- stateSerializerExprs
Value
[source, scala]¶
stateSerializerExprs: Seq[Expression]¶
NOTE: stateSerializerExprs
is part of the <UnsafeRow
).
stateSerializerExprs
...FIXME
=== [[stateDeserializerExpr]] State Deserializer -- stateDeserializerExpr
Value
[source, scala]¶
stateDeserializerExpr: Expression¶
NOTE: stateDeserializerExpr
is part of the <UnsafeRow
).
stateDeserializerExpr
...FIXME
=== [[internal-properties]] Internal Properties
[cols="30m,70",options="header",width="100%"] |=== | Name | Description
| nestedStateOrdinal a| [[nestedStateOrdinal]] Position of the state in a state row (0
)
Used when...FIXME
| timeoutTimestampOrdinalInRow a| [[timeoutTimestampOrdinalInRow]] Position of the timeout timestamp in a state row (1
)
Used when...FIXME
|===