Modifier and Type | Class and Description |
---|---|
class |
RocksDBStateBackend
A State Backend that stores its state in
RocksDB . |
Modifier and Type | Method and Description |
---|---|
StateBackend |
RocksDBStateBackend.getCheckpointBackend()
Gets the state backend that this RocksDB state backend uses to persist its bytes to.
|
Constructor and Description |
---|
RocksDBStateBackend(StateBackend checkpointStreamBackend)
Creates a new
RocksDBStateBackend that uses the given state backend to store its
checkpoint data streams. |
RocksDBStateBackend(StateBackend checkpointStreamBackend,
TernaryBoolean enableIncrementalCheckpointing)
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 |
---|---|
static void |
Checkpoints.disposeSavepoint(String pointer,
StateBackend stateBackend,
ClassLoader classLoader) |
Modifier and Type | Method and Description |
---|---|
void |
ExecutionGraph.enableCheckpointing(CheckpointCoordinatorConfiguration chkConfig,
List<ExecutionJobVertex> verticesToTrigger,
List<ExecutionJobVertex> verticesToWaitFor,
List<ExecutionJobVertex> verticesToCommitTo,
List<MasterTriggerRestoreHook<?>> masterHooks,
CheckpointIDCounter checkpointIDCounter,
CompletedCheckpointStore checkpointStore,
StateBackend checkpointStateBackend,
CheckpointStatsTracker statsTracker) |
Modifier and Type | Method and Description |
---|---|
SerializedValue<StateBackend> |
JobCheckpointingSettings.getDefaultStateBackend() |
Constructor and Description |
---|
JobCheckpointingSettings(List<JobVertexID> verticesToTrigger,
List<JobVertexID> verticesToAcknowledge,
List<JobVertexID> verticesToConfirm,
CheckpointCoordinatorConfiguration checkpointCoordinatorConfiguration,
SerializedValue<StateBackend> defaultStateBackend) |
JobCheckpointingSettings(List<JobVertexID> verticesToTrigger,
List<JobVertexID> verticesToAcknowledge,
List<JobVertexID> verticesToConfirm,
CheckpointCoordinatorConfiguration checkpointCoordinatorConfiguration,
SerializedValue<StateBackend> defaultStateBackend,
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 | Class and Description |
---|---|
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,
Configuration config,
ClassLoader classLoader,
org.slf4j.Logger logger)
Checks if an application-defined state backend is given, and if not, loads the state backend
from the configuration, from the parameter 'state.backend', as defined in
CheckpointingOptions.STATE_BACKEND . |
static StateBackend |
StateBackendLoader.loadStateBackendFromConfig(ReadableConfig config,
ClassLoader classLoader,
org.slf4j.Logger logger)
Loads the state backend from the configuration, from the parameter 'state.backend', as
defined in
CheckpointingOptions.STATE_BACKEND . |
Modifier and Type | Method and Description |
---|---|
static StateBackend |
StateBackendLoader.fromApplicationOrConfigOrDefault(StateBackend fromApplication,
Configuration config,
ClassLoader classLoader,
org.slf4j.Logger logger)
Checks if an application-defined state backend is given, and if not, loads the state backend
from the configuration, from the parameter 'state.backend', as defined in
CheckpointingOptions.STATE_BACKEND . |
Modifier and Type | Class and Description |
---|---|
class |
AbstractFileStateBackend
A base class for all state backends that store their metadata (and data) in files.
|
class |
FsStateBackend
This state backend holds the working state in the memory (JVM heap) of the TaskManagers.
|
Modifier and Type | Class and Description |
---|---|
class |
MemoryStateBackend
This state backend holds the working state in the memory (JVM heap) of the TaskManagers.
|
Modifier and Type | Field and Description |
---|---|
protected StateBackend |
WritableSavepoint.stateBackend
The state backend to use when writing this savepoint.
|
Modifier and Type | Method and Description |
---|---|
static NewSavepoint |
Savepoint.create(StateBackend stateBackend,
int maxParallelism)
Creates a new savepoint.
|
static ExistingSavepoint |
Savepoint.load(ExecutionEnvironment env,
String path,
StateBackend stateBackend)
Loads an existing savepoint.
|
Constructor and Description |
---|
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.
|
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 and checkpoint operator state.
|
Modifier and Type | Method and Description |
---|---|
StateBackend |
StreamGraph.getStateBackend() |
StateBackend |
StreamConfig.getStateBackend(ClassLoader cl) |
Modifier and Type | Method and Description |
---|---|
void |
StreamGraph.setStateBackend(StateBackend backend) |
void |
StreamConfig.setStateBackend(StateBackend backend) |
StreamGraphGenerator |
StreamGraphGenerator.setStateBackend(StateBackend stateBackend) |
Constructor and Description |
---|
StreamTaskStateInitializerImpl(Environment environment,
StateBackend stateBackend) |
StreamTaskStateInitializerImpl(Environment environment,
StateBackend stateBackend,
TtlTimeProvider ttlTimeProvider) |
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) |
Modifier and Type | Method and Description |
---|---|
StateBackend |
DummyStreamExecutionEnvironment.getStateBackend() |
Modifier and Type | Method and Description |
---|---|
StreamExecutionEnvironment |
DummyStreamExecutionEnvironment.setStateBackend(StateBackend backend) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.