public class JobSnapshottingSettings extends Object implements Serializable
Constructor and Description |
---|
JobSnapshottingSettings(List<JobVertexID> verticesToTrigger,
List<JobVertexID> verticesToAcknowledge,
List<JobVertexID> verticesToConfirm,
long checkpointInterval,
long checkpointTimeout,
long minPauseBetweenCheckpoints,
int maxConcurrentCheckpoints) |
Modifier and Type | Method and Description |
---|---|
long |
getCheckpointInterval() |
long |
getCheckpointTimeout() |
int |
getMaxConcurrentCheckpoints() |
long |
getMinPauseBetweenCheckpoints() |
String |
getSavepointPath()
Returns the configured savepoint path or
null if none is configured. |
List<JobVertexID> |
getVerticesToAcknowledge() |
List<JobVertexID> |
getVerticesToConfirm() |
List<JobVertexID> |
getVerticesToTrigger() |
void |
setSavepointPath(String savepointPath)
Sets the savepoint path.
|
String |
toString() |
public JobSnapshottingSettings(List<JobVertexID> verticesToTrigger, List<JobVertexID> verticesToAcknowledge, List<JobVertexID> verticesToConfirm, long checkpointInterval, long checkpointTimeout, long minPauseBetweenCheckpoints, int maxConcurrentCheckpoints)
public List<JobVertexID> getVerticesToTrigger()
public List<JobVertexID> getVerticesToAcknowledge()
public List<JobVertexID> getVerticesToConfirm()
public long getCheckpointInterval()
public long getCheckpointTimeout()
public long getMinPauseBetweenCheckpoints()
public int getMaxConcurrentCheckpoints()
public void setSavepointPath(String savepointPath)
savepointPath
- The path of the savepoint to resume from.public String getSavepointPath()
null
if none is configured.null
if none is configured.Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.