Skip to content

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.

Last update: 2020-11-28