Modifier and Type | Class and Description |
---|---|
class |
EmbeddedRocksDBStateBackend
A
StateBackend that stores its state in an embedded RocksDB instance. |
class |
RocksDBStateBackend
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
StateBackend |
RocksDBStateBackend.getCheckpointBackend()
Deprecated.
Gets the state backend that this RocksDB state backend uses to persist its bytes to.
|
Constructor and Description |
---|
RocksDBStateBackend(StateBackend checkpointStreamBackend)
Deprecated.
Creates a new
RocksDBStateBackend that uses the given state backend to store its
checkpoint data streams. |
RocksDBStateBackend(StateBackend checkpointStreamBackend,
TernaryBoolean enableIncrementalCheckpointing)
Deprecated.
Creates a new
RocksDBStateBackend that uses the given state backend to store its
checkpoint data streams. |
Modifier and Type | Method and Description |
---|---|
static StateBackend |
Checkpoints.loadStateBackend(Configuration configuration,
ClassLoader classLoader,
org.slf4j.Logger logger) |
Modifier and Type | Method and Description |
---|---|
void |
DefaultExecutionGraph.enableCheckpointing(CheckpointCoordinatorConfiguration chkConfig,
List<MasterTriggerRestoreHook<?>> masterHooks,
CheckpointIDCounter checkpointIDCounter,
CompletedCheckpointStore checkpointStore,
StateBackend checkpointStateBackend,
CheckpointStorage checkpointStorage,
CheckpointStatsTracker statsTracker,
CheckpointsCleaner checkpointsCleaner,
String changelogStorageName) |
void |
ExecutionGraph.enableCheckpointing(CheckpointCoordinatorConfiguration chkConfig,
List<MasterTriggerRestoreHook<?>> masterHooks,
CheckpointIDCounter checkpointIDCounter,
CompletedCheckpointStore checkpointStore,
StateBackend checkpointStateBackend,
CheckpointStorage checkpointStorage,
CheckpointStatsTracker statsTracker,
CheckpointsCleaner checkpointsCleaner,
String changelogStorage) |
Modifier and Type | Method and Description |
---|---|
SerializedValue<StateBackend> |
JobCheckpointingSettings.getDefaultStateBackend() |
Constructor and Description |
---|
JobCheckpointingSettings(CheckpointCoordinatorConfiguration checkpointCoordinatorConfiguration,
SerializedValue<StateBackend> defaultStateBackend) |
JobCheckpointingSettings(CheckpointCoordinatorConfiguration checkpointCoordinatorConfiguration,
SerializedValue<StateBackend> defaultStateBackend,
TernaryBoolean changelogStateBackendEnabled,
SerializedValue<CheckpointStorage> defaultCheckpointStorage,
SerializedValue<MasterTriggerRestoreHook.Factory[]> masterHooks) |
Modifier and Type | Interface and Description |
---|---|
interface |
StateBackendFactory<T extends StateBackend>
A factory to create a specific state backend.
|
Modifier and Type | Interface and Description |
---|---|
interface |
ConfigurableStateBackend
An interface for state backends that pick up additional parameters from a configuration.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractManagedMemoryStateBackend
Abstract base class for state backends that use managed memory.
|
class |
AbstractStateBackend
An abstract base implementation of the
StateBackend interface. |
Modifier and Type | Method and Description |
---|---|
StateBackend |
ConfigurableStateBackend.configure(ReadableConfig config,
ClassLoader classLoader)
Creates a variant of the state backend that applies additional configuration parameters.
|
static StateBackend |
StateBackendLoader.fromApplicationOrConfigOrDefault(StateBackend fromApplication,
TernaryBoolean isChangelogStateBackendEnableFromApplication,
Configuration config,
ClassLoader classLoader,
org.slf4j.Logger logger)
This is the state backend loader that loads a
DelegatingStateBackend wrapping the
state backend loaded from StateBackendLoader.loadFromApplicationOrConfigOrDefaultInternal(org.apache.flink.runtime.state.StateBackend, org.apache.flink.configuration.Configuration, java.lang.ClassLoader, org.slf4j.Logger) when delegation is enabled. |
static StateBackend |
StateBackendLoader.loadStateBackendFromConfig(ReadableConfig config,
ClassLoader classLoader,
org.slf4j.Logger logger)
Loads the unwrapped state backend from the configuration, from the parameter 'state.backend',
as defined in
StateBackendOptions.STATE_BACKEND . |
static StateBackend |
StateBackendLoader.loadStateBackendFromKeyedStateHandles(StateBackend originalStateBackend,
ClassLoader classLoader,
Collection<KeyedStateHandle> keyedStateHandles)
Load state backend which may wrap the original state backend for recovery.
|
Modifier and Type | Method and Description |
---|---|
static StateBackend |
StateBackendLoader.fromApplicationOrConfigOrDefault(StateBackend fromApplication,
TernaryBoolean isChangelogStateBackendEnableFromApplication,
Configuration config,
ClassLoader classLoader,
org.slf4j.Logger logger)
This is the state backend loader that loads a
DelegatingStateBackend wrapping the
state backend loaded from StateBackendLoader.loadFromApplicationOrConfigOrDefaultInternal(org.apache.flink.runtime.state.StateBackend, org.apache.flink.configuration.Configuration, java.lang.ClassLoader, org.slf4j.Logger) when delegation is enabled. |
static boolean |
StateBackendLoader.isChangelogStateBackend(StateBackend backend) |
static CheckpointStorage |
CheckpointStorageLoader.load(CheckpointStorage fromApplication,
Path defaultSavepointDirectory,
StateBackend configuredStateBackend,
Configuration config,
ClassLoader classLoader,
org.slf4j.Logger logger)
Loads the configured
CheckpointStorage for the job based on the following precedent
rules: |
static StateBackend |
StateBackendLoader.loadStateBackendFromKeyedStateHandles(StateBackend originalStateBackend,
ClassLoader classLoader,
Collection<KeyedStateHandle> keyedStateHandles)
Load state backend which may wrap the original state backend for recovery.
|
Modifier and Type | Interface and Description |
---|---|
interface |
DelegatingStateBackend
An interface to delegate state backend.
|
Modifier and Type | Method and Description |
---|---|
StateBackend |
DelegatingStateBackend.getDelegatedStateBackend() |
Modifier and Type | Class and Description |
---|---|
class |
AbstractFileStateBackend
Deprecated.
State backends should no longer implement
CheckpointStorage functionality.
Please inherit AbstractStateBackend instead. Custom checkpoint storage can be
additionally implemented as a separate class. |
class |
FsStateBackend
Deprecated.
|
Modifier and Type | Class and Description |
---|---|
class |
HashMapStateBackend
This state backend holds the working state in the memory (JVM heap) of the TaskManagers and
checkpoints based on the configured
CheckpointStorage . |
Modifier and Type | Class and Description |
---|---|
class |
MemoryStateBackend
Deprecated.
|
Modifier and Type | Field and Description |
---|---|
protected StateBackend |
WritableSavepoint.stateBackend
Deprecated.
The state backend to use when writing this savepoint.
|
protected StateBackend |
SavepointWriter.stateBackend
The state backend to use when writing this savepoint.
|
Modifier and Type | Method and Description |
---|---|
static NewSavepoint |
Savepoint.create(StateBackend stateBackend,
int maxParallelism)
Deprecated.
Creates a new savepoint.
|
static SavepointWriter |
SavepointWriter.fromExistingSavepoint(StreamExecutionEnvironment executionEnvironment,
String path,
StateBackend stateBackend)
Loads an existing savepoint.
|
static SavepointWriter |
SavepointWriter.fromExistingSavepoint(String path,
StateBackend stateBackend)
|
static ExistingSavepoint |
Savepoint.load(ExecutionEnvironment env,
String path,
StateBackend stateBackend)
Deprecated.
Loads an existing savepoint.
|
static SavepointWriter |
SavepointWriter.newSavepoint(StateBackend stateBackend,
int maxParallelism)
|
static SavepointWriter |
SavepointWriter.newSavepoint(StreamExecutionEnvironment executionEnvironment,
StateBackend stateBackend,
int maxParallelism)
Creates a new savepoint.
|
static SavepointReader |
SavepointReader.read(StreamExecutionEnvironment env,
String path,
StateBackend stateBackend)
Loads an existing savepoint.
|
Constructor and Description |
---|
BroadcastStateInputFormat(OperatorState operatorState,
Configuration configuration,
StateBackend backend,
MapStateDescriptor<K,V> descriptor)
Creates an input format for reading broadcast state from an operator in a savepoint.
|
KeyedStateInputFormat(OperatorState operatorState,
StateBackend stateBackend,
Configuration configuration,
StateReaderOperator<?,K,N,OUT> operator)
Creates an input format for reading partitioned state from an operator in a savepoint.
|
ListStateInputFormat(OperatorState operatorState,
Configuration configuration,
StateBackend backend,
ListStateDescriptor<OT> descriptor)
Creates an input format for reading list state from an operator in a savepoint.
|
UnionStateInputFormat(OperatorState operatorState,
Configuration configuration,
StateBackend backend,
ListStateDescriptor<OT> descriptor)
Creates an input format for reading union state from an operator in a savepoint.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractChangelogStateBackend
An abstract base implementation of the
StateBackend interface whose subclasses use
delegatedStateBackend and State changes to restore. |
class |
ChangelogStateBackend
This state backend holds the working state in the underlying delegatedStateBackend, and forwards
state changes to State Changelog.
|
class |
DeactivatedChangelogStateBackend
This state backend use delegatedStateBackend and State changes to restore to the
delegatedStateBackend in which switching Changelog from enabled to disabled.
|
Modifier and Type | Field and Description |
---|---|
protected StateBackend |
AbstractChangelogStateBackend.delegatedStateBackend |
Modifier and Type | Method and Description |
---|---|
StateBackend |
ChangelogStateBackend.configure(ReadableConfig config,
ClassLoader classLoader) |
StateBackend |
AbstractChangelogStateBackend.getDelegatedStateBackend() |
Modifier and Type | Method and Description |
---|---|
StateBackend |
StreamExecutionEnvironment.getStateBackend()
Gets the state backend that defines how to store and checkpoint state.
|
Modifier and Type | Method and Description |
---|---|
StreamExecutionEnvironment |
StreamExecutionEnvironment.setStateBackend(StateBackend backend)
Sets the state backend that describes how to store operator.
|
Modifier and Type | Method and Description |
---|---|
StateBackend |
StreamGraph.getStateBackend() |
StateBackend |
StreamConfig.getStateBackend(ClassLoader cl) |
Modifier and Type | Method and Description |
---|---|
StreamGraphGenerator |
StreamGraphGenerator.setStateBackend(StateBackend stateBackend) |
void |
StreamConfig.setStateBackend(StateBackend backend) |
void |
StreamGraph.setStateBackend(StateBackend backend) |
Constructor and Description |
---|
StreamTaskStateInitializerImpl(Environment environment,
StateBackend stateBackend) |
StreamTaskStateInitializerImpl(Environment environment,
StateBackend stateBackend,
TtlTimeProvider ttlTimeProvider,
InternalTimeServiceManager.Provider timeServiceManagerProvider) |
Modifier and Type | Class and Description |
---|---|
class |
BatchExecutionStateBackend
A simple
StateBackend which is used in a BATCH style execution. |
Modifier and Type | Field and Description |
---|---|
protected StateBackend |
StreamTask.stateBackend
Our state backend.
|
Modifier and Type | Method and Description |
---|---|
StateBackend |
DummyStreamExecutionEnvironment.getStateBackend() |
Modifier and Type | Method and Description |
---|---|
StreamExecutionEnvironment |
DummyStreamExecutionEnvironment.setStateBackend(StateBackend backend) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.