Package | Description |
---|---|
org.apache.flink.runtime.state | |
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.
|
org.apache.flink.runtime.state.internal |
This package holds the classes of the internal state type hierarchy.
|
Modifier and Type | Class and Description |
---|---|
static class |
StateEntry.SimpleStateEntry<K,N,S> |
Modifier and Type | Method and Description |
---|---|
default StateEntry<K,N,S> |
StateEntry.filterOrTransform(StateSnapshotTransformer<S> transformer) |
Modifier and Type | Method and Description |
---|---|
Iterator<StateEntry<K,N,S>> |
IterableStateSnapshot.getIterator(int keyGroup) |
Modifier and Type | Class and Description |
---|---|
protected static class |
CopyOnWriteStateMap.StateMapEntry<K,N,S>
One entry in the
CopyOnWriteStateMap . |
Modifier and Type | Method and Description |
---|---|
Iterator<StateEntry<K,N,S>> |
CopyOnWriteSkipListStateMapSnapshot.getIterator(TypeSerializer<K> keySerializer,
TypeSerializer<N> namespaceSerializer,
TypeSerializer<S> stateSerializer,
StateSnapshotTransformer<S> stateSnapshotTransformer) |
Iterator<StateEntry<K,N,S>> |
NestedStateMapSnapshot.getIterator(TypeSerializer<K> keySerializer,
TypeSerializer<N> namespaceSerializer,
TypeSerializer<S> stateSerializer,
StateSnapshotTransformer<S> stateSnapshotTransformer) |
abstract Iterator<StateEntry<K,N,S>> |
StateMapSnapshot.getIterator(TypeSerializer<K> keySerializer,
TypeSerializer<N> namespaceSerializer,
TypeSerializer<S> stateSerializer,
StateSnapshotTransformer<S> stateSnapshotTransformer) |
Iterator<StateEntry<K,N,S>> |
CopyOnWriteSkipListStateMap.iterator() |
Iterator<StateEntry<K,N,S>> |
NestedStateMap.iterator() |
Iterator<StateEntry<K,N,S>> |
CopyOnWriteStateMap.iterator() |
Iterator<StateEntry<K,N,S>> |
StateTable.iterator() |
Modifier and Type | Method and Description |
---|---|
Collection<StateEntry<K,N,V>> |
InternalKvState.StateIncrementalVisitor.nextEntries()
Return some next entries which are available at the moment.
|
Modifier and Type | Method and Description |
---|---|
void |
InternalKvState.StateIncrementalVisitor.remove(StateEntry<K,N,V> stateEntry) |
void |
InternalKvState.StateIncrementalVisitor.update(StateEntry<K,N,V> stateEntry,
V newValue)
Update the value of the last returned entry from the
next() method. |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.