put(store: StateStore, row: UnsafeRow): Unit
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
Note
|
put is part of the StreamingAggregationStateManager Contract to store a row in a state store.
|
put
…FIXME