org.apache.flink.api.common.state.v2

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>, ListState<T>, ReducingState<T>

All Known Implementing Classes:

ForStListState, InternalAggregatingState, InternalListState, InternalReducingState

@Experimental
public interface MergingState<IN,OUT,SYNCOUT>
extends AppendingState<IN,OUT,SYNCOUT>

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.v2.AppendingState

add, asyncAdd, asyncGet, get

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

asyncClear, clear