public class TriggerCheckpoint extends AbstractCheckpointMessage implements Serializable
JobManager
to the
TaskManager
to tell a certain task to trigger its
checkpoint.Constructor and Description |
---|
TriggerCheckpoint(JobID job,
ExecutionAttemptID taskExecutionId,
long checkpointId,
long timestamp) |
Modifier and Type | Method and Description |
---|---|
boolean |
equals(Object o) |
long |
getTimestamp() |
int |
hashCode() |
String |
toString() |
getCheckpointId, getJob, getTaskExecutionId
public TriggerCheckpoint(JobID job, ExecutionAttemptID taskExecutionId, long checkpointId, long timestamp)
public long getTimestamp()
public int hashCode()
hashCode
in class AbstractCheckpointMessage
public boolean equals(Object o)
equals
in class AbstractCheckpointMessage
public String toString()
toString
in class AbstractCheckpointMessage
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.