StreamingAggregationStateManagerImplV1 — Legacy State Manager for Streaming Aggregation

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.

StreamingAggregationStateManagerImplV1 is created exclusively when StreamingAggregationStateManager is requested for a new StreamingAggregationStateManager.

Storing Row in State Store — put Method

put(store: StateStore, row: UnsafeRow): Unit
Note
 put is part of the StreamingAggregationStateManager Contract to store a row in a state store.

put…​FIXME

Creating StreamingAggregationStateManagerImplV1 Instance

StreamingAggregationStateManagerImplV1 takes the following when created:

  • Attribute expressions for keys (Seq[Attribute])

  • Attribute expressions of input rows (Seq[Attribute])

results matching ""

    No results matching ""