StreamingAggregationStateManagerBaseImpl¶
StreamingAggregationStateManagerBaseImpl is a base implementation of the StreamingAggregationStateManager abstraction for state managers for streaming aggregations.
Implementations¶
StreamingAggregationStateManagerImplV1(legacy)- StreamingAggregationStateManagerImplV2
Creating Instance¶
StreamingAggregationStateManagerBaseImpl takes the following to be created:
Abstract Class
StreamingAggregationStateManagerBaseImpl is an abstract class and cannot be created directly. It is created indirectly for the concrete StreamingAggregationStateManagerBaseImpls.
Committing State Changes¶
commit(
store: StateStore): Long
commit is part of the StreamingAggregationStateManager abstraction.
commit requests the given StateStore to commit state changes.
Extracting Key¶
getKey(
row: UnsafeRow): UnsafeRow
getKey is part of the StreamingAggregationStateManager abstraction.
getKey uses the keyProjector to extract a key from the given row.
Removing Key¶
remove(
store: StateStore,
key: UnsafeRow): Unit
remove is part of the StreamingAggregationStateManager abstraction.
remove requests the given StateStore to remove the given key.