Class CheckpointConfigInfo
- java.lang.Object
-
- org.apache.flink.runtime.rest.messages.checkpoints.CheckpointConfigInfo
-
- All Implemented Interfaces:
ResponseBody
public class CheckpointConfigInfo extends Object implements ResponseBody
Response class of theCheckpointConfigHandler
.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
CheckpointConfigInfo.ExternalizedCheckpointInfo
Contains information about the externalized checkpoint configuration.static class
CheckpointConfigInfo.ProcessingMode
Processing mode.static class
CheckpointConfigInfo.ProcessingModeDeserializer
Processing mode deserializer.static class
CheckpointConfigInfo.ProcessingModeSerializer
JSON deserializer forCheckpointConfigInfo.ProcessingMode
.
-
Field Summary
Fields Modifier and Type Field Description static String
FIELD_NAME_ALIGNED_CHECKPOINT_TIMEOUT
static String
FIELD_NAME_CHANGELOG_STORAGE
static String
FIELD_NAME_CHECKPOINT_INTERVAL
static String
FIELD_NAME_CHECKPOINT_MAX_CONCURRENT
static String
FIELD_NAME_CHECKPOINT_MIN_PAUSE
static String
FIELD_NAME_CHECKPOINT_STORAGE
static String
FIELD_NAME_CHECKPOINT_TIMEOUT
static String
FIELD_NAME_CHECKPOINTS_AFTER_TASKS_FINISH
static String
FIELD_NAME_EXTERNALIZED_CHECKPOINT_CONFIG
static String
FIELD_NAME_PERIODIC_MATERIALIZATION_INTERVAL
static String
FIELD_NAME_PROCESSING_MODE
static String
FIELD_NAME_STATE_BACKEND
static String
FIELD_NAME_STATE_CHANGELOG
static String
FIELD_NAME_TOLERABLE_FAILED_CHECKPOINTS
static String
FIELD_NAME_UNALIGNED_CHECKPOINTS
-
Constructor Summary
Constructors Constructor Description CheckpointConfigInfo(CheckpointConfigInfo.ProcessingMode processingMode, long checkpointInterval, long checkpointTimeout, long minPauseBetweenCheckpoints, int maxConcurrentCheckpoints, CheckpointConfigInfo.ExternalizedCheckpointInfo externalizedCheckpointInfo, String stateBackend, String checkpointStorage, boolean unalignedCheckpoints, int tolerableFailedCheckpoints, long alignedCheckpointTimeout, boolean checkpointsWithFinishedTasks, boolean stateChangelog, long periodicMaterializationInterval, String changelogStorage)
-
-
-
Field Detail
-
FIELD_NAME_PROCESSING_MODE
public static final String FIELD_NAME_PROCESSING_MODE
- See Also:
- Constant Field Values
-
FIELD_NAME_CHECKPOINT_INTERVAL
public static final String FIELD_NAME_CHECKPOINT_INTERVAL
- See Also:
- Constant Field Values
-
FIELD_NAME_CHECKPOINT_TIMEOUT
public static final String FIELD_NAME_CHECKPOINT_TIMEOUT
- See Also:
- Constant Field Values
-
FIELD_NAME_CHECKPOINT_MIN_PAUSE
public static final String FIELD_NAME_CHECKPOINT_MIN_PAUSE
- See Also:
- Constant Field Values
-
FIELD_NAME_CHECKPOINT_MAX_CONCURRENT
public static final String FIELD_NAME_CHECKPOINT_MAX_CONCURRENT
- See Also:
- Constant Field Values
-
FIELD_NAME_EXTERNALIZED_CHECKPOINT_CONFIG
public static final String FIELD_NAME_EXTERNALIZED_CHECKPOINT_CONFIG
- See Also:
- Constant Field Values
-
FIELD_NAME_STATE_BACKEND
public static final String FIELD_NAME_STATE_BACKEND
- See Also:
- Constant Field Values
-
FIELD_NAME_CHECKPOINT_STORAGE
public static final String FIELD_NAME_CHECKPOINT_STORAGE
- See Also:
- Constant Field Values
-
FIELD_NAME_UNALIGNED_CHECKPOINTS
public static final String FIELD_NAME_UNALIGNED_CHECKPOINTS
- See Also:
- Constant Field Values
-
FIELD_NAME_TOLERABLE_FAILED_CHECKPOINTS
public static final String FIELD_NAME_TOLERABLE_FAILED_CHECKPOINTS
- See Also:
- Constant Field Values
-
FIELD_NAME_ALIGNED_CHECKPOINT_TIMEOUT
public static final String FIELD_NAME_ALIGNED_CHECKPOINT_TIMEOUT
- See Also:
- Constant Field Values
-
FIELD_NAME_CHECKPOINTS_AFTER_TASKS_FINISH
public static final String FIELD_NAME_CHECKPOINTS_AFTER_TASKS_FINISH
- See Also:
- Constant Field Values
-
FIELD_NAME_STATE_CHANGELOG
public static final String FIELD_NAME_STATE_CHANGELOG
- See Also:
- Constant Field Values
-
FIELD_NAME_PERIODIC_MATERIALIZATION_INTERVAL
public static final String FIELD_NAME_PERIODIC_MATERIALIZATION_INTERVAL
- See Also:
- Constant Field Values
-
FIELD_NAME_CHANGELOG_STORAGE
public static final String FIELD_NAME_CHANGELOG_STORAGE
- See Also:
- Constant Field Values
-
-
Constructor Detail
-
CheckpointConfigInfo
public CheckpointConfigInfo(CheckpointConfigInfo.ProcessingMode processingMode, long checkpointInterval, long checkpointTimeout, long minPauseBetweenCheckpoints, int maxConcurrentCheckpoints, CheckpointConfigInfo.ExternalizedCheckpointInfo externalizedCheckpointInfo, String stateBackend, String checkpointStorage, boolean unalignedCheckpoints, int tolerableFailedCheckpoints, long alignedCheckpointTimeout, boolean checkpointsWithFinishedTasks, boolean stateChangelog, long periodicMaterializationInterval, String changelogStorage)
-
-