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 chained operator state and the key group state.
Constructor and Description |
---|
AcknowledgeCheckpoint(JobID job,
ExecutionAttemptID taskExecutionId,
CheckpointMetaData checkpointMetaData) |
AcknowledgeCheckpoint(JobID job,
ExecutionAttemptID taskExecutionId,
CheckpointMetaData checkpointMetaData,
SubtaskState subtaskState) |
Modifier and Type | Method and Description |
---|---|
boolean |
equals(Object o) |
CheckpointMetaData |
getCheckpointMetaData() |
SubtaskState |
getSubtaskState() |
int |
hashCode() |
String |
toString() |
getCheckpointId, getJob, getTaskExecutionId
public AcknowledgeCheckpoint(JobID job, ExecutionAttemptID taskExecutionId, CheckpointMetaData checkpointMetaData)
public AcknowledgeCheckpoint(JobID job, ExecutionAttemptID taskExecutionId, CheckpointMetaData checkpointMetaData, SubtaskState subtaskState)
public SubtaskState getSubtaskState()
public CheckpointMetaData getCheckpointMetaData()
public boolean equals(Object o)
equals
in class AbstractCheckpointMessage
public int hashCode()
hashCode
in class AbstractCheckpointMessage
public String toString()
toString
in class AbstractCheckpointMessage
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.