Package org.apache.flink.runtime.state.internal

Interface InternalMergingState<K,N,IN,SV,OUT>

Type Parameters:

K - The type of key the state is associated to

N - The type of the namespace

IN - The type of elements added to the state

SV - The type of elements in the state

OUT - The type of elements

All Superinterfaces:

AppendingState<IN,OUT>, InternalAppendingState<K,N,IN,SV,OUT>, InternalKvState<K,N,SV>, MergingState<IN,OUT>, State

All Known Subinterfaces:

InternalAggregatingState<K,N,IN,SV,OUT>, InternalListState<K,N,T>, InternalReducingState<K,N,T>

public interface InternalMergingState<K,N,IN,SV,OUT>
extends InternalAppendingState<K,N,IN,SV,OUT>, MergingState<IN,OUT>

The peer to the MergingState in the internal state type hierarchy.

See InternalKvState for a description of the internal state hierarchy.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.flink.runtime.state.internal.InternalKvState

InternalKvState.StateIncrementalVisitor<K,N,V>

Method Summary

Modifier and Type	Method	Description
void	mergeNamespaces(N target, Collection<N> sources)	Merges the state of the current key for the given source namespaces into the state of the target namespace.

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

add, get

Methods inherited from interface org.apache.flink.runtime.state.internal.InternalAppendingState

getInternal, updateInternal

Methods inherited from interface org.apache.flink.runtime.state.internal.InternalKvState

getKeySerializer, getNamespaceSerializer, getSerializedValue, getStateIncrementalVisitor, getValueSerializer, setCurrentNamespace

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

clear

Method Detail

mergeNamespaces

void mergeNamespaces(N target,
                     Collection<N> sources)
              throws Exception

Merges the state of the current key for the given source namespaces into the state of the target namespace.

Parameters:

target - The target namespace where the merged state should be stored.

sources - The source namespaces whose state should be merged.

Throws:

Exception - The method may forward exception thrown internally (by I/O or functions).