public class AcknowledgeCheckpoint extends AbstractCheckpointMessage implements Serializable
TaskManager
to the
JobManager
to signal that the checkpoint of an
individual task is completed.
This message may carry the handle to the task's state.Constructor and Description |
---|
AcknowledgeCheckpoint(JobID job,
ExecutionAttemptID taskExecutionId,
long checkpointId) |
AcknowledgeCheckpoint(JobID job,
ExecutionAttemptID taskExecutionId,
long checkpointId,
SerializedValue<StateHandle<?>> state,
long stateSize) |
Modifier and Type | Method and Description |
---|---|
boolean |
equals(Object o) |
SerializedValue<StateHandle<?>> |
getState() |
long |
getStateSize() |
String |
toString() |
getCheckpointId, getJob, getTaskExecutionId, hashCode
public AcknowledgeCheckpoint(JobID job, ExecutionAttemptID taskExecutionId, long checkpointId)
public AcknowledgeCheckpoint(JobID job, ExecutionAttemptID taskExecutionId, long checkpointId, SerializedValue<StateHandle<?>> state, long stateSize)
public SerializedValue<StateHandle<?>> getState()
public long getStateSize()
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.