public class CheckpointingOptions extends Object
Modifier and Type | Field and Description |
---|---|
static ConfigOption<Boolean> |
ASYNC_SNAPSHOTS
Deprecated.
Checkpoints are always asynchronous.
|
static ConfigOption<String> |
CHECKPOINT_STORAGE
The checkpoint storage used to checkpoint state for recovery.
|
static ConfigOption<String> |
CHECKPOINTS_DIRECTORY
The default directory used for storing the data files and meta data of checkpoints in a Flink
supported filesystem.
|
static ConfigOption<Boolean> |
CLEANER_PARALLEL_MODE |
static ConfigOption<MemorySize> |
FS_SMALL_FILE_THRESHOLD
The minimum size of state data files.
|
static ConfigOption<Integer> |
FS_WRITE_BUFFER_SIZE
The default size of the write buffer for the checkpoint streams that write to file systems.
|
static ConfigOption<Boolean> |
INCREMENTAL_CHECKPOINTS
Option whether the state backend should create incremental checkpoints, if possible.
|
static ConfigOption<Boolean> |
LOCAL_RECOVERY
This option configures local recovery for this state backend.
|
static ConfigOption<String> |
LOCAL_RECOVERY_TASK_MANAGER_STATE_ROOT_DIRS
The config parameter defining the root directories for storing file-based state for local
recovery.
|
static ConfigOption<Integer> |
MAX_RETAINED_CHECKPOINTS
The maximum number of completed checkpoints to retain.
|
static ConfigOption<String> |
SAVEPOINT_DIRECTORY
The default directory for savepoints.
|
static ConfigOption<String> |
STATE_BACKEND
Deprecated.
|
Constructor and Description |
---|
CheckpointingOptions() |
@Deprecated public static final ConfigOption<String> STATE_BACKEND
StateBackendOptions.STATE_BACKEND
.The implementation can be specified either via their shortcut name, or via the class name
of a StateBackendFactory
. If a StateBackendFactory class name is specified, the
factory is instantiated (via its zero-argument constructor) and its StateBackendFactory#createFromConfig(ReadableConfig, ClassLoader)
method is called.
Recognized shortcut names are 'hashmap' and 'rocksdb'.
public static final ConfigOption<String> CHECKPOINT_STORAGE
The implementation can be specified either via their shortcut name, or via the class name
of a CheckpointStorageFactory
. If a CheckpointStorageFactory class name is specified,
the factory is instantiated (via its zero-argument constructor) and its CheckpointStorageFactory#createFromConfig(ReadableConfig, ClassLoader)
method is called.
Recognized shortcut names are 'jobmanager' and 'filesystem'.
public static final ConfigOption<Integer> MAX_RETAINED_CHECKPOINTS
public static final ConfigOption<Boolean> CLEANER_PARALLEL_MODE
@Deprecated public static final ConfigOption<Boolean> ASYNC_SNAPSHOTS
public static final ConfigOption<Boolean> INCREMENTAL_CHECKPOINTS
Once enabled, the state size shown in web UI or fetched from rest API only represents the delta checkpoint size instead of full checkpoint size.
Some state backends may not support incremental checkpoints and ignore this option.
public static final ConfigOption<Boolean> LOCAL_RECOVERY
Local recovery currently only covers keyed state backends (including both the EmbeddedRocksDBStateBackend and the HashMapStateBackend).
public static final ConfigOption<String> LOCAL_RECOVERY_TASK_MANAGER_STATE_ROOT_DIRS
Local recovery currently only covers keyed state backends. Currently, MemoryStateBackend does not support local recovery and ignore this option.
public static final ConfigOption<String> SAVEPOINT_DIRECTORY
public static final ConfigOption<String> CHECKPOINTS_DIRECTORY
public static final ConfigOption<MemorySize> FS_SMALL_FILE_THRESHOLD
public static final ConfigOption<Integer> FS_WRITE_BUFFER_SIZE
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.