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 | 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 isPreferCheckpointForRecovery,
int tolerableCpFailureNumber) |
Modifier and Type | Method and Description |
---|---|
boolean |
equals(Object o) |
long |
getCheckpointInterval() |
CheckpointRetentionPolicy |
getCheckpointRetentionPolicy() |
long |
getCheckpointTimeout() |
int |
getMaxConcurrentCheckpoints() |
long |
getMinPauseBetweenCheckpoints() |
int |
getTolerableCheckpointFailureNumber() |
int |
hashCode() |
boolean |
isExactlyOnce() |
boolean |
isPreferCheckpointForRecovery() |
String |
toString() |
public static final long MINIMAL_CHECKPOINT_TIME
public CheckpointCoordinatorConfiguration(long checkpointInterval, long checkpointTimeout, long minPauseBetweenCheckpoints, int maxConcurrentCheckpoints, CheckpointRetentionPolicy checkpointRetentionPolicy, boolean isExactlyOnce, boolean isPreferCheckpointForRecovery, int tolerableCpFailureNumber)
public long getCheckpointInterval()
public long getCheckpointTimeout()
public long getMinPauseBetweenCheckpoints()
public int getMaxConcurrentCheckpoints()
public CheckpointRetentionPolicy getCheckpointRetentionPolicy()
public boolean isExactlyOnce()
public boolean isPreferCheckpointForRecovery()
public int getTolerableCheckpointFailureNumber()
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.