InternalAggregatingState<K,N,IN,ACC,OUT> |
This class defines the internal interface for aggregating state.
|
InternalAppendingState<K,N,IN,SV,OUT,SYNCOUT> |
This class defines the internal interface for appending state.
|
InternalKeyedState<K,N,V> |
This class defines the internal interface for all keyed state.
|
InternalListState<K,N,V> |
This class defines the internal interface for list state.
|
InternalMapState<K,N,UK,UV> |
This class defines the internal interface for map state.
|
InternalMergingState<K,N,IN,SV,OUT,SYNCOUT> |
This class defines the internal interface for merging state.
|
InternalPartitionedState<N> |
A state that is partitioned into different namespaces.
|
InternalReducingState<K,N,T> |
This class defines the internal interface for reducing state.
|
InternalValueState<K,N,V> |
This class defines the internal interface for value state.
|