package statevariables
Type Members
- class ListStateImpl[S] extends ListStateMetricsImpl with ListState[S] with Logging
Provides concrete implementation for list of values associated with a state variable used in the streaming transformWithState operator.
Provides concrete implementation for list of values associated with a state variable used in the streaming transformWithState operator.
- S
- data type of object that will be stored in the list
- trait ListStateMetricsImpl extends AnyRef
Trait that provides helper methods to maintain metrics for a list state.
Trait that provides helper methods to maintain metrics for a list state. For list state, we keep track of the count of entries in the list in a separate column family to get an accurate view of the number of entries that are updated/removed from the list and reported as part of the query progress metrics.
- class MapStateImpl[K, V] extends MapState[K, V] with Logging
Class that provides a concrete implementation for map state associated with state variables used in the streaming transformWithState operator.
Class that provides a concrete implementation for map state associated with state variables used in the streaming transformWithState operator.
- K
- type of key for map state variable
- V
- type of value for map state variable
- class ValueStateImpl[S] extends ValueState[S] with Logging
Class that provides a concrete implementation for a single value state associated with state variables used in the streaming transformWithState operator.
Class that provides a concrete implementation for a single value state associated with state variables used in the streaming transformWithState operator.
- S
- data type of object that will be stored