Package org.apache.flink.runtime.state.heap

This package contains the classes for key/value state backends that store the state on the JVM heap as objects.

See: Description

Interface Summary

Interface	Description
InternalKeyContext<K>	This interface is the current context of a keyed state.
StateEntry<K,N,S>	Interface of entries in a state table.

Class Summary

Class	Description
AbstractHeapMergingState<K,N,IN,OUT,SV,S extends State,SD extends StateDescriptor<S,?>>	Base class for MergingState (InternalMergingState) that is stored on the heap.
AbstractHeapState<K,N,SV,S extends State,SD extends StateDescriptor<S,?>>	Base class for partitioned ListState implementations that are backed by a regular heap hash map.
CopyOnWriteStateTable<K,N,S>	Implementation of Flink's in-memory state tables with copy-on-write support.
CopyOnWriteStateTableSnapshot<K,N,S>	This class represents the snapshot of a CopyOnWriteStateTable and has a role in operator state checkpointing.
HeapAggregatingState<K,N,IN,ACC,OUT>	Heap-backed partitioned ReducingState that is snapshotted into files.
HeapFoldingState<K,N,T,ACC>	Deprecated will be removed in a future version
HeapKeyedStateBackend<K>	A AbstractKeyedStateBackend that keeps state on the Java Heap and will serialize state to streams provided by a CheckpointStreamFactory upon checkpointing.
HeapListState<K,N,V>	Heap-backed partitioned ListState that is snapshotted into files.
HeapMapState<K,N,UK,UV>	Heap-backed partitioned MapState that is snapshotted into files.
HeapReducingState<K,N,V>	Heap-backed partitioned ReducingState that is snapshotted into files.
HeapValueState<K,N,V>	Heap-backed partitioned ValueState that is snapshotted into files.
NestedMapsStateTable<K,N,S>	This implementation of StateTable uses nested HashMap objects.
StateTable<K,N,S>	Base class for state tables.

Package org.apache.flink.runtime.state.heap Description

This package contains the classes for key/value state backends that store the state on the JVM heap as objects.