Package org.apache.flink.runtime.state.v2.adaptor
-
Class Summary Class Description AggregatingStateAdaptor<K,N,IN,ACC,OUT> An adaptor that transformsInternalAggregatingState
intoInternalAggregatingState
.AsyncKeyedStateBackendAdaptor<K> A adaptor that transformsKeyedStateBackend
intoAsyncKeyedStateBackend
.CompleteStateIterator<T> AStateIterator
that has all elements.ListStateAdaptor<K,N,V> An adaptor that transformsInternalListState
intoInternalListState
.MapStateAdaptor<K,N,UK,UV> An adaptor that transformsInternalMapState
intoInternalMapState
.MergingStateAdaptor<K,N,IN,ACC,OUT,SYNCOUT> An adaptor that transformsInternalMergingState
intoInternalMergingState
.ReducingStateAdaptor<K,N,V> An adaptor that transformsInternalReducingState
intoInternalReducingState
.StateAdaptor<K,N,S extends InternalKvState<K,N,?>> An base implementation of state adaptor from v1 to v2.ValueStateAdaptor<K,N,V> An adaptor that transformsInternalValueState
intoInternalValueState
.