Uses of Class
org.apache.flink.runtime.state.heap.StateMap

Packages that use StateMap

Package	Description
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.

Uses of StateMap in org.apache.flink.runtime.state.heap

Classes in org.apache.flink.runtime.state.heap with type parameters of type StateMap

Modifier and Type	Class and Description
class	StateMapSnapshot<K,N,S,T extends StateMap<K,N,S>> Base class for snapshots of a StateMap.

Subclasses of StateMap in org.apache.flink.runtime.state.heap

Modifier and Type	Class and Description
class	CopyOnWriteSkipListStateMap<K,N,S> Implementation of state map which is based on skip list with copy-on-write support. states will be serialized to bytes and stored in the space allocated with the given allocator.
class	CopyOnWriteStateMap<K,N,S> Implementation of Flink's in-memory state maps with copy-on-write support.

Fields in org.apache.flink.runtime.state.heap declared as StateMap

Modifier and Type	Field and Description
protected StateMap<K,N,S>[]	StateTable.keyGroupedStateMaps Map for holding the actual state objects.
protected T	StateMapSnapshot.owningStateMap The StateMap from which this snapshot was created.

Methods in org.apache.flink.runtime.state.heap that return StateMap

Modifier and Type	Method and Description
protected abstract StateMap<K,N,S>	StateTable.createStateMap()
StateMap<K,N,S>	StateTable.getMapForKeyGroup(int keyGroupIndex)
StateMap<K,N,S>[]	StateTable.getState() Returns the internal data structure.

Methods in org.apache.flink.runtime.state.heap that return types with arguments of type StateMap

Modifier and Type	Method and Description
protected StateMapSnapshot<K,N,S,? extends StateMap<K,N,S>>	CopyOnWriteStateTableSnapshot.getStateMapSnapshotForKeyGroup(int keyGroup)
abstract StateMapSnapshot<K,N,S,? extends StateMap<K,N,S>>	StateMap.stateSnapshot() Creates a snapshot of this StateMap, to be written in checkpointing.

Method parameters in org.apache.flink.runtime.state.heap with type arguments of type StateMap

Modifier and Type	Method and Description
void	CopyOnWriteSkipListStateMap.releaseSnapshot(StateMapSnapshot<K,N,S,? extends StateMap<K,N,S>> snapshotToRelease)
void	StateMap.releaseSnapshot(StateMapSnapshot<K,N,S,? extends StateMap<K,N,S>> snapshotToRelease) Releases a snapshot for this StateMap.
void	CopyOnWriteStateMap.releaseSnapshot(StateMapSnapshot<K,N,S,? extends StateMap<K,N,S>> snapshotToRelease) Releases a snapshot for this CopyOnWriteStateMap.