Interface MergingState<IN,OUT,SYNCOUT>
-
- Type Parameters:
IN
- Type of the value that can be added to the state.OUT
- Type of the value that can be retrieved from the state.
- All Superinterfaces:
AppendingState<IN,OUT,SYNCOUT>
,State
- All Known Subinterfaces:
AggregatingState<IN,OUT>
,InternalAggregatingState<K,N,IN,ACC,OUT>
,InternalListState<K,N,V>
,InternalMergingState<K,N,IN,SV,OUT,SYNCOUT>
,InternalReducingState<K,N,T>
,ListState<T>
,ReducingState<T>
- All Known Implementing Classes:
AbstractAggregatingState
,AbstractListState
,AbstractReducingState
,AggregatingStateAdaptor
,ForStAggregatingState
,ForStListState
,ForStReducingState
,ListStateAdaptor
,MergingStateAdaptor
,ReducingStateAdaptor
@Experimental public interface MergingState<IN,OUT,SYNCOUT> extends AppendingState<IN,OUT,SYNCOUT>
Extension ofAppendingState
that allows merging of state. That is, two instances ofMergingState
can be combined into a single instance that contains all the information of the two merged states.
-
-
Method Summary
-
Methods inherited from interface org.apache.flink.api.common.state.v2.AppendingState
add, asyncAdd, asyncGet, get
-
Methods inherited from interface org.apache.flink.api.common.state.v2.State
asyncClear, clear
-
-