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