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

Interface InternalKeyedState<K,N,V>

Type Parameters:

K - The type of key the state is associated to.

N - The namespace type.

V - The type of the intermediate state.

All Superinterfaces:

InternalPartitionedState<N>, State

All Known Subinterfaces:

InternalAggregatingState<K,N,IN,ACC,OUT>, InternalAppendingState<K,N,IN,SV,OUT,SYNCOUT>, InternalListState<K,N,V>, InternalMapState<K,N,UK,UV>, InternalMergingState<K,N,IN,SV,OUT,SYNCOUT>, InternalReducingState<K,N,T>, InternalValueState<K,N,V>

All Known Implementing Classes:

AbstractAggregatingState, AbstractKeyedState, AbstractListState, AbstractMapState, AbstractReducingState, AbstractValueState, AggregatingStateAdaptor, ForStAggregatingState, ForStListState, ForStMapState, ForStReducingState, ForStValueState, ListStateAdaptor, MapStateAdaptor, MergingStateAdaptor, ReducingStateAdaptor, ValueStateAdaptor

@Internal
public interface InternalKeyedState<K,N,V>
extends InternalPartitionedState<N>, State

This class defines the internal interface for all keyed state.

Method Summary

Methods inherited from interface org.apache.flink.runtime.state.v2.internal.InternalPartitionedState

setCurrentNamespace

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

asyncClear, clear