org.apache.flink.runtime.rest.messages.checkpoints

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 the CheckpointConfigHandler.

Nested Class Summary

Nested Classes

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.

Field Summary

Fields

Modifier and Type	Field and 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 and 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)

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object o)
int	hashCode()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait

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)

Method Detail

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object