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() |
List<JobVertexID> |
getVerticesToAcknowledge() |
List<JobVertexID> |
getVerticesToConfirm() |
List<JobVertexID> |
getVerticesToTrigger() |
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()
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.