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.Constructor and Description |
---|
CheckpointCoordinatorConfiguration(long checkpointInterval,
long checkpointTimeout,
long minPauseBetweenCheckpoints,
int maxConcurrentCheckpoints,
ExternalizedCheckpointSettings externalizedCheckpointSettings,
boolean isExactlyOnce) |
Modifier and Type | Method and Description |
---|---|
boolean |
equals(Object o) |
long |
getCheckpointInterval() |
long |
getCheckpointTimeout() |
ExternalizedCheckpointSettings |
getExternalizedCheckpointSettings() |
int |
getMaxConcurrentCheckpoints() |
long |
getMinPauseBetweenCheckpoints() |
int |
hashCode() |
boolean |
isExactlyOnce() |
String |
toString() |
public CheckpointCoordinatorConfiguration(long checkpointInterval, long checkpointTimeout, long minPauseBetweenCheckpoints, int maxConcurrentCheckpoints, ExternalizedCheckpointSettings externalizedCheckpointSettings, boolean isExactlyOnce)
public long getCheckpointInterval()
public long getCheckpointTimeout()
public long getMinPauseBetweenCheckpoints()
public int getMaxConcurrentCheckpoints()
public ExternalizedCheckpointSettings getExternalizedCheckpointSettings()
public boolean isExactlyOnce()
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.