org.apache.flink.runtime.state.internal

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

Type Parameters:

K - The type of key the state is associated to

N - The type of the namespace

IN - Type of the value added to the state

SV - The type of elements in the state

OUT - Type of the value extracted from the state

All Superinterfaces:

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

public interface InternalAggregatingState<K,N,IN,SV,OUT>
extends InternalMergingState<K,N,IN,SV,OUT>, AggregatingState<IN,OUT>

The peer to the AggregatingState 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

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

mergeNamespaces

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