Uses of Interface
org.apache.flink.api.common.state.v2.MergingState
-
-
Uses of MergingState in org.apache.flink.api.common.state.v2
Subinterfaces of MergingState in org.apache.flink.api.common.state.v2 Modifier and Type Interface Description interface
AggregatingState<IN,OUT>
State
interface for aggregating state, based on anAggregateFunction
.interface
ListState<T>
State
interface for partitioned list state in Operations.interface
ReducingState<T>
State
interface for reducing state. -
Uses of MergingState in org.apache.flink.runtime.state.v2
Classes in org.apache.flink.runtime.state.v2 that implement MergingState Modifier and Type Class Description class
AbstractAggregatingState<K,N,IN,ACC,OUT>
The default implementation ofAggregatingState
, which delegates all async requests toStateRequestHandler
.class
AbstractListState<K,N,V>
A default implementation ofListState
which delegates all async requests toStateRequestHandler
.class
AbstractReducingState<K,N,V>
A default implementation ofReducingState
which delegates all async requests toStateRequestHandler
. -
Uses of MergingState in org.apache.flink.runtime.state.v2.adaptor
Classes in org.apache.flink.runtime.state.v2.adaptor that implement MergingState Modifier and Type Class Description class
AggregatingStateAdaptor<K,N,IN,ACC,OUT>
An adaptor that transformsInternalAggregatingState
intoInternalAggregatingState
.class
ListStateAdaptor<K,N,V>
An adaptor that transformsInternalListState
intoInternalListState
.class
MergingStateAdaptor<K,N,IN,ACC,OUT,SYNCOUT>
An adaptor that transformsInternalMergingState
intoInternalMergingState
.class
ReducingStateAdaptor<K,N,V>
An adaptor that transformsInternalReducingState
intoInternalReducingState
. -
Uses of MergingState in org.apache.flink.runtime.state.v2.internal
Subinterfaces of MergingState in org.apache.flink.runtime.state.v2.internal Modifier and Type Interface Description interface
InternalAggregatingState<K,N,IN,ACC,OUT>
This class defines the internal interface for aggregating state.interface
InternalListState<K,N,V>
This class defines the internal interface for list state.interface
InternalMergingState<K,N,IN,SV,OUT,SYNCOUT>
This class defines the internal interface for merging state.interface
InternalReducingState<K,N,T>
This class defines the internal interface for reducing state. -
Uses of MergingState in org.apache.flink.state.forst
Classes in org.apache.flink.state.forst that implement MergingState Modifier and Type Class Description class
ForStAggregatingState<K,N,IN,ACC,OUT>
The implementation ofAggregatingState
for ForStDB.class
ForStListState<K,N,V>
TheAbstractListState
implement for ForStDB.class
ForStReducingState<K,N,V>
TheAbstractReducingState
implement for ForStDB.
-