@PublicEvolving public class ExecutionCheckpointingOptions extends Object
ConfigOption
for configuring checkpointing related parameters.CheckpointConfig
Modifier and Type | Field and Description |
---|---|
static ConfigOption<java.time.Duration> |
CHECKPOINTING_INTERVAL |
static ConfigOption<CheckpointingMode> |
CHECKPOINTING_MODE |
static ConfigOption<java.time.Duration> |
CHECKPOINTING_TIMEOUT |
static ConfigOption<CheckpointConfig.ExternalizedCheckpointCleanup> |
EXTERNALIZED_CHECKPOINT |
static ConfigOption<Integer> |
MAX_CONCURRENT_CHECKPOINTS |
static ConfigOption<java.time.Duration> |
MIN_PAUSE_BETWEEN_CHECKPOINTS |
static ConfigOption<Boolean> |
PREFER_CHECKPOINT_FOR_RECOVERY |
static ConfigOption<Integer> |
TOLERABLE_FAILURE_NUMBER |
Constructor and Description |
---|
ExecutionCheckpointingOptions() |
public static final ConfigOption<CheckpointingMode> CHECKPOINTING_MODE
public static final ConfigOption<java.time.Duration> CHECKPOINTING_TIMEOUT
public static final ConfigOption<Integer> MAX_CONCURRENT_CHECKPOINTS
public static final ConfigOption<java.time.Duration> MIN_PAUSE_BETWEEN_CHECKPOINTS
public static final ConfigOption<Boolean> PREFER_CHECKPOINT_FOR_RECOVERY
public static final ConfigOption<Integer> TOLERABLE_FAILURE_NUMBER
public static final ConfigOption<CheckpointConfig.ExternalizedCheckpointCleanup> EXTERNALIZED_CHECKPOINT
public static final ConfigOption<java.time.Duration> CHECKPOINTING_INTERVAL
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.