public class CompletedCheckpoint extends Object implements Serializable
Constructor and Description |
---|
CompletedCheckpoint(JobID job,
long checkpointID,
long timestamp,
long completionTimestamp,
Map<JobVertexID,TaskState> taskStates) |
CompletedCheckpoint(JobID job,
long checkpointID,
long timestamp,
long completionTimestamp,
Map<JobVertexID,TaskState> taskStates,
CheckpointProperties props,
String externalPath) |
Modifier and Type | Method and Description |
---|---|
boolean |
discard(JobStatus jobStatus) |
boolean |
equals(Object obj) |
long |
getCheckpointID() |
long |
getDuration() |
String |
getExternalPath() |
JobID |
getJobId() |
CheckpointProperties |
getProperties() |
long |
getStateSize() |
TaskState |
getTaskState(JobVertexID jobVertexID) |
Map<JobVertexID,TaskState> |
getTaskStates() |
long |
getTimestamp() |
int |
hashCode() |
boolean |
subsume() |
String |
toString() |
public CompletedCheckpoint(JobID job, long checkpointID, long timestamp, long completionTimestamp, Map<JobVertexID,TaskState> taskStates)
public CompletedCheckpoint(JobID job, long checkpointID, long timestamp, long completionTimestamp, Map<JobVertexID,TaskState> taskStates, CheckpointProperties props, String externalPath)
public JobID getJobId()
public long getCheckpointID()
public long getTimestamp()
public long getDuration()
public CheckpointProperties getProperties()
public long getStateSize()
public Map<JobVertexID,TaskState> getTaskStates()
public TaskState getTaskState(JobVertexID jobVertexID)
public String getExternalPath()
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.