org.apache.flink.api.common.state

Interface MergingState<IN,OUT>

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>, State

All Known Subinterfaces:

AggregatingState<IN,OUT>, InternalAggregatingState<K,N,IN,SV,OUT>, InternalListState<K,N,T>, InternalMergingState<K,N,IN,SV,OUT>, InternalReducingState<K,N,T>, ListState<T>, ReducingState<T>

All Known Implementing Classes:

ImmutableAggregatingState, ImmutableListState, ImmutableReducingState, PartitionableListState, SimpleVersionedListState

@PublicEvolving
public interface MergingState<IN,OUT>
extends AppendingState<IN,OUT>

Extension of AppendingState that allows merging of state. That is, two instances of MergingState 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.AppendingState

add, get

Methods inherited from interface org.apache.flink.api.common.state.State

clear