StreamingAggregationStateManagerImplV1¶
StreamingAggregationStateManagerImplV1 is the legacy state manager for streaming aggregations.
Note
The version of a state manager is controlled using spark.sql.streaming.aggregation.stateFormatVersion internal configuration property.
Storing Row in State Store¶
put(
store: StateStore,
row: UnsafeRow): Unit
put is part of the StreamingAggregationStateManager abstraction.
put...FIXME
Creating Instance¶
StreamingAggregationStateManagerImplV1 takes the following when created:
- [[keyExpressions]] Attribute expressions for keys (
Seq[Attribute]) - [[inputRowAttributes]] Attribute expressions of input rows (
Seq[Attribute])
StreamingAggregationStateManagerImplV1 is created when StreamingAggregationStateManager is requested for a new StreamingAggregationStateManager.