public class CheckpointCoordinatorConfiguration extends Object implements Serializable
CheckpointCoordinator
. This includes the checkpoint
interval, the checkpoint timeout, the pause between checkpoints, the maximum number of concurrent
checkpoints and settings for externalized checkpoints.Modifier and Type | Class and Description |
---|---|
static class |
CheckpointCoordinatorConfiguration.CheckpointCoordinatorConfigurationBuilder
CheckpointCoordinatorConfiguration builder. |
Modifier and Type | Field and Description |
---|---|
static long |
MINIMAL_CHECKPOINT_TIME |
Constructor and Description |
---|
CheckpointCoordinatorConfiguration(long checkpointInterval,
long checkpointTimeout,
long minPauseBetweenCheckpoints,
int maxConcurrentCheckpoints,
CheckpointRetentionPolicy checkpointRetentionPolicy,
boolean isExactlyOnce,
boolean isUnalignedCheckpoint,
boolean isPreferCheckpointForRecovery,
int tolerableCpFailureNumber)
Deprecated.
use
builder() . |
Modifier and Type | Method and Description |
---|---|
static CheckpointCoordinatorConfiguration.CheckpointCoordinatorConfigurationBuilder |
builder() |
boolean |
equals(Object o) |
long |
getAlignmentTimeout() |
long |
getCheckpointInterval() |
CheckpointRetentionPolicy |
getCheckpointRetentionPolicy() |
long |
getCheckpointTimeout() |
int |
getMaxConcurrentCheckpoints() |
long |
getMinPauseBetweenCheckpoints() |
int |
getTolerableCheckpointFailureNumber() |
int |
hashCode() |
boolean |
isExactlyOnce() |
boolean |
isPreferCheckpointForRecovery() |
boolean |
isUnalignedCheckpointsEnabled() |
String |
toString() |
public static final long MINIMAL_CHECKPOINT_TIME
@Deprecated @VisibleForTesting public CheckpointCoordinatorConfiguration(long checkpointInterval, long checkpointTimeout, long minPauseBetweenCheckpoints, int maxConcurrentCheckpoints, CheckpointRetentionPolicy checkpointRetentionPolicy, boolean isExactlyOnce, boolean isUnalignedCheckpoint, boolean isPreferCheckpointForRecovery, int tolerableCpFailureNumber)
builder()
.public long getCheckpointInterval()
public long getCheckpointTimeout()
public long getMinPauseBetweenCheckpoints()
public int getMaxConcurrentCheckpoints()
public CheckpointRetentionPolicy getCheckpointRetentionPolicy()
public boolean isExactlyOnce()
public boolean isPreferCheckpointForRecovery()
public int getTolerableCheckpointFailureNumber()
public boolean isUnalignedCheckpointsEnabled()
public long getAlignmentTimeout()
public static CheckpointCoordinatorConfiguration.CheckpointCoordinatorConfigurationBuilder builder()
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.