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

add, get

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).