@PublicEvolving public class StateRecoveryOptions extends Object
configuration options
used when restoring state from a savepoint or a
checkpoint.Modifier and Type | Field and Description |
---|---|
static ConfigOption<Boolean> |
APPROXIMATE_LOCAL_RECOVERY
Access to this option is officially only supported via
org.apache.flink.runtime.jobgraph.CheckpointConfig#enableApproximateLocalRecovery(boolean) ,
but there is no good reason behind this. |
static ConfigOption<Long> |
CHECKPOINT_ID_OF_IGNORED_IN_FLIGHT_DATA |
static ConfigOption<Boolean> |
LOCAL_RECOVERY
This option configures local recovery for the state backend, which indicates whether to
recovery from local snapshot.
|
static ConfigOption<RestoreMode> |
RESTORE_MODE
Describes the mode how Flink should restore from the given savepoint or retained checkpoint.
|
static ConfigOption<Boolean> |
SAVEPOINT_IGNORE_UNCLAIMED_STATE
A flag indicating if we allow Flink to skip savepoint state that cannot be restored, e.g.
|
static ConfigOption<String> |
SAVEPOINT_PATH
The path to a savepoint that will be used to bootstrap the pipeline's state.
|
Constructor and Description |
---|
StateRecoveryOptions() |
public static final ConfigOption<String> SAVEPOINT_PATH
public static final ConfigOption<Boolean> SAVEPOINT_IGNORE_UNCLAIMED_STATE
public static final ConfigOption<RestoreMode> RESTORE_MODE
@Internal public static final ConfigOption<Boolean> APPROXIMATE_LOCAL_RECOVERY
org.apache.flink.runtime.jobgraph.CheckpointConfig#enableApproximateLocalRecovery(boolean)
,
but there is no good reason behind this.public static final ConfigOption<Long> CHECKPOINT_ID_OF_IGNORED_IN_FLIGHT_DATA
public static final ConfigOption<Boolean> LOCAL_RECOVERY
Local recovery currently only covers keyed state backends (including both the EmbeddedRocksDBStateBackend and the HashMapStateBackend).
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.