Modifier and Type | Class and Description |
---|---|
class |
RocksDBStateBackend
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
static CheckpointStorage |
Checkpoints.loadCheckpointStorage(Configuration configuration,
ClassLoader classLoader,
org.slf4j.Logger logger) |
Modifier and Type | Method and Description |
---|---|
static void |
Checkpoints.disposeSavepoint(String pointer,
CheckpointStorage checkpointStorage,
ClassLoader classLoader) |
Modifier and Type | Method and Description |
---|---|
void |
ExecutionGraph.enableCheckpointing(CheckpointCoordinatorConfiguration chkConfig,
List<MasterTriggerRestoreHook<?>> masterHooks,
CheckpointIDCounter checkpointIDCounter,
CompletedCheckpointStore checkpointStore,
StateBackend checkpointStateBackend,
CheckpointStorage checkpointStorage,
CheckpointStatsTracker statsTracker,
CheckpointsCleaner checkpointsCleaner) |
void |
DefaultExecutionGraph.enableCheckpointing(CheckpointCoordinatorConfiguration chkConfig,
List<MasterTriggerRestoreHook<?>> masterHooks,
CheckpointIDCounter checkpointIDCounter,
CompletedCheckpointStore checkpointStore,
StateBackend checkpointStateBackend,
CheckpointStorage checkpointStorage,
CheckpointStatsTracker statsTracker,
CheckpointsCleaner checkpointsCleaner) |
Modifier and Type | Method and Description |
---|---|
SerializedValue<CheckpointStorage> |
JobCheckpointingSettings.getDefaultCheckpointStorage() |
Constructor and Description |
---|
JobCheckpointingSettings(CheckpointCoordinatorConfiguration checkpointCoordinatorConfiguration,
SerializedValue<StateBackend> defaultStateBackend,
TernaryBoolean changelogStateBackendEnabled,
SerializedValue<CheckpointStorage> defaultCheckpointStorage,
SerializedValue<MasterTriggerRestoreHook.Factory[]> masterHooks) |
Modifier and Type | Interface and Description |
---|---|
interface |
CheckpointStorageFactory<T extends CheckpointStorage>
A factory to create a specific
CheckpointStorage . |
Modifier and Type | Interface and Description |
---|---|
interface |
ConfigurableCheckpointStorage
An interface for checkpoint storage types that pick up additional parameters from a
configuration.
|
Modifier and Type | Method and Description |
---|---|
CheckpointStorage |
ConfigurableCheckpointStorage.configure(ReadableConfig config,
ClassLoader classLoader)
Creates a variant of the checkpoint storage that applies additional configuration parameters.
|
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: |
Modifier and Type | Method and Description |
---|---|
static Optional<CheckpointStorage> |
CheckpointStorageLoader.fromConfig(ReadableConfig config,
ClassLoader classLoader,
org.slf4j.Logger logger)
Loads the checkpoint storage from the configuration, from the parameter
'state.checkpoint-storage', as defined in
CheckpointingOptions.CHECKPOINT_STORAGE . |
Modifier and Type | Method and Description |
---|---|
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: |
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 |
MemoryStateBackend
Deprecated.
|
Modifier and Type | Class and Description |
---|---|
class |
FileSystemCheckpointStorage
FileSystemCheckpointStorage checkpoints state as files to a file system. |
class |
JobManagerCheckpointStorage
The
CheckpointStorage checkpoints state directly to the JobManager's memory (hence the
name), but savepoints will be persisted to a file system. |
Modifier and Type | Method and Description |
---|---|
CheckpointStorage |
CheckpointConfig.getCheckpointStorage() |
Modifier and Type | Method and Description |
---|---|
void |
CheckpointConfig.setCheckpointStorage(CheckpointStorage storage)
CheckpointStorage defines how
StateBackend 's checkpoint their state for fault
tolerance in streaming applications. |
Modifier and Type | Method and Description |
---|---|
CheckpointStorage |
StreamGraph.getCheckpointStorage() |
CheckpointStorage |
StreamConfig.getCheckpointStorage(ClassLoader cl) |
Modifier and Type | Method and Description |
---|---|
void |
StreamGraph.setCheckpointStorage(CheckpointStorage checkpointStorage) |
void |
StreamConfig.setCheckpointStorage(CheckpointStorage storage) |
Modifier and Type | Class and Description |
---|---|
class |
BatchExecutionCheckpointStorage
A simple
CheckpointStorage which is used in a BATCH style execution. |
Modifier and Type | Field and Description |
---|---|
protected CheckpointStorage |
StreamTask.checkpointStorage
Our checkpoint storage.
|
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.