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.metainfo |
Modifier and Type | Method and Description |
---|---|
StateMetaInfoSnapshot |
StateSnapshot.getMetaInfoSnapshot()
Returns a snapshot of the state's meta data.
|
StateMetaInfoSnapshot |
RegisteredKeyValueStateBackendMetaInfo.snapshot() |
StateMetaInfoSnapshot |
RegisteredOperatorStateBackendMetaInfo.snapshot() |
StateMetaInfoSnapshot |
RegisteredBroadcastStateBackendMetaInfo.snapshot() |
StateMetaInfoSnapshot |
RegisteredPriorityQueueStateBackendMetaInfo.snapshot() |
abstract StateMetaInfoSnapshot |
RegisteredStateMetaInfoBase.snapshot() |
Modifier and Type | Method and Description |
---|---|
List<StateMetaInfoSnapshot> |
OperatorBackendSerializationProxy.getBroadcastStateMetaInfoSnapshots() |
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 |
StateMetaInfoReader.readStateMetaInfoSnapshot(DataInputView inputView,
ClassLoader userCodeClassLoader)
Reads a snapshot from the given input view.
|
StateMetaInfoSnapshot |
LegacyStateMetaInfoReaders.OperatorBackendStateMetaInfoReaderV1.readStateMetaInfoSnapshot(DataInputView in,
ClassLoader userCodeClassLoader) |
Modifier and Type | Method and Description |
---|---|
void |
StateMetaInfoWriter.writeStateMetaInfoSnapshot(StateMetaInfoSnapshot snapshot,
DataOutputView outputView)
Writes the given snapshot to the output view.
|
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.