StreamingAggregationStateManagerBaseImpl takes the following to be created:
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.
getKey( row: UnsafeRow): UnsafeRow
getKey is part of the StreamingAggregationStateManager abstraction.
getKey uses the keyProjector to extract a key from the given
remove( store: StateStore, key: UnsafeRow): Unit
remove is part of the StreamingAggregationStateManager abstraction.