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.
|
Modifier and Type | Class and Description |
---|---|
class |
CopyOnWriteSkipListStateMapSnapshot<K,N,S>
This class represents the snapshot of a
CopyOnWriteSkipListStateMap . |
class |
CopyOnWriteStateMapSnapshot<K,N,S>
This class represents the snapshot of a
CopyOnWriteStateMap . |
class |
NestedStateMapSnapshot<K,N,S>
This class represents the snapshot of a
NestedStateMap . |
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. |
StateMapSnapshot<K,N,S,? extends StateMap<K,N,S>> |
NestedStateMap.stateSnapshot() |
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 . |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.