Package | Description |
---|---|
org.apache.flink.contrib.streaming.state.snapshot | |
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.metainfo | |
org.apache.flink.runtime.state.restore |
Modifier and Type | Method and Description |
---|---|
List<StateMetaInfoSnapshot> |
RocksDBFullSnapshotResources.getMetaInfoSnapshots() |
Constructor and Description |
---|
RocksDBFullSnapshotResources(ResourceGuard.Lease lease,
org.rocksdb.Snapshot snapshot,
List<RocksDBKeyedStateBackend.RocksDbKvStateInfo> metaDataCopy,
List<HeapPriorityQueueStateSnapshot<?>> heapPriorityQueuesSnapshots,
List<StateMetaInfoSnapshot> stateMetaInfoSnapshots,
org.rocksdb.RocksDB db,
int keyGroupPrefixBytes,
KeyGroupRange keyGroupRange,
TypeSerializer<K> keySerializer,
StreamCompressionDecorator streamCompressionDecorator) |
Modifier and Type | Method and Description |
---|---|
StateMetaInfoSnapshot |
StateSnapshot.getMetaInfoSnapshot()
Returns a snapshot of the state's meta data.
|
StateMetaInfoSnapshot |
RegisteredKeyValueStateBackendMetaInfo.snapshot() |
StateMetaInfoSnapshot |
RegisteredPriorityQueueStateBackendMetaInfo.snapshot() |
StateMetaInfoSnapshot |
RegisteredOperatorStateBackendMetaInfo.snapshot() |
abstract StateMetaInfoSnapshot |
RegisteredStateMetaInfoBase.snapshot() |
StateMetaInfoSnapshot |
RegisteredBroadcastStateBackendMetaInfo.snapshot() |
Modifier and Type | Method and Description |
---|---|
List<StateMetaInfoSnapshot> |
OperatorBackendSerializationProxy.getBroadcastStateMetaInfoSnapshots() |
List<StateMetaInfoSnapshot> |
FullSnapshotResources.getMetaInfoSnapshots()
Returns the list of
meta info snapshots for this state
snapshot. |
List<StateMetaInfoSnapshot> |
OperatorBackendSerializationProxy.getOperatorStateMetaInfoSnapshots() |
List<StateMetaInfoSnapshot> |
KeyedBackendSerializationProxy.getStateMetaInfoSnapshots() |
Modifier and Type | Method and Description |
---|---|
static RegisteredStateMetaInfoBase |
RegisteredStateMetaInfoBase.fromMetaInfoSnapshot(StateMetaInfoSnapshot snapshot) |
Constructor and Description |
---|
RegisteredBroadcastStateBackendMetaInfo(StateMetaInfoSnapshot snapshot) |
RegisteredKeyValueStateBackendMetaInfo(StateMetaInfoSnapshot snapshot) |
RegisteredOperatorStateBackendMetaInfo(StateMetaInfoSnapshot snapshot) |
RegisteredPriorityQueueStateBackendMetaInfo(StateMetaInfoSnapshot snapshot) |
Constructor and Description |
---|
KeyedBackendSerializationProxy(TypeSerializer<K> keySerializer,
List<StateMetaInfoSnapshot> stateMetaInfoSnapshots,
boolean compression) |
OperatorBackendSerializationProxy(List<StateMetaInfoSnapshot> operatorStateMetaInfoSnapshots,
List<StateMetaInfoSnapshot> broadcastStateMetaInfoSnapshots) |
OperatorBackendSerializationProxy(List<StateMetaInfoSnapshot> operatorStateMetaInfoSnapshots,
List<StateMetaInfoSnapshot> broadcastStateMetaInfoSnapshots) |
Modifier and Type | Method and Description |
---|---|
StateMetaInfoSnapshot |
HeapPriorityQueueStateSnapshot.getMetaInfoSnapshot() |
Modifier and Type | Method and Description |
---|---|
StateMetaInfoSnapshot |
LegacyStateMetaInfoReaders.OperatorBackendStateMetaInfoReaderV1.readStateMetaInfoSnapshot(DataInputView in,
ClassLoader userCodeClassLoader) |
StateMetaInfoSnapshot |
StateMetaInfoReader.readStateMetaInfoSnapshot(DataInputView inputView,
ClassLoader userCodeClassLoader)
Reads a snapshot from the given input view.
|
Modifier and Type | Method and Description |
---|---|
void |
StateMetaInfoWriter.writeStateMetaInfoSnapshot(StateMetaInfoSnapshot snapshot,
DataOutputView outputView)
Writes the given snapshot to the output view.
|
Modifier and Type | Method and Description |
---|---|
List<StateMetaInfoSnapshot> |
SavepointRestoreResult.getStateMetaInfoSnapshots() |
Constructor and Description |
---|
SavepointRestoreResult(List<StateMetaInfoSnapshot> stateMetaInfoSnapshots,
ThrowingIterator<KeyGroup> groupsIterator) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.