public class CheckpointConfigInfo extends Object implements ResponseBody
CheckpointConfigHandler
.Modifier and Type | Class and 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 for
CheckpointConfigInfo.ProcessingMode . |
Modifier and Type | Field and Description |
---|---|
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_TIMEOUT |
static String |
FIELD_NAME_EXTERNALIZED_CHECKPOINT_CONFIG |
static String |
FIELD_NAME_PROCESSING_MODE |
Constructor and Description |
---|
CheckpointConfigInfo(CheckpointConfigInfo.ProcessingMode processingMode,
long checkpointInterval,
long checkpointTimeout,
long minPauseBetweenCheckpoints,
int maxConcurrentCheckpoints,
CheckpointConfigInfo.ExternalizedCheckpointInfo externalizedCheckpointInfo) |
public static final String FIELD_NAME_PROCESSING_MODE
public static final String FIELD_NAME_CHECKPOINT_INTERVAL
public static final String FIELD_NAME_CHECKPOINT_TIMEOUT
public static final String FIELD_NAME_CHECKPOINT_MIN_PAUSE
public static final String FIELD_NAME_CHECKPOINT_MAX_CONCURRENT
public static final String FIELD_NAME_EXTERNALIZED_CHECKPOINT_CONFIG
public CheckpointConfigInfo(CheckpointConfigInfo.ProcessingMode processingMode, long checkpointInterval, long checkpointTimeout, long minPauseBetweenCheckpoints, int maxConcurrentCheckpoints, CheckpointConfigInfo.ExternalizedCheckpointInfo externalizedCheckpointInfo)
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.