org.apache.flink.runtime.messages.checkpoint

Class AcknowledgeCheckpoint

java.lang.Object

org.apache.flink.runtime.messages.checkpoint.AbstractCheckpointMessage

org.apache.flink.runtime.messages.checkpoint.AcknowledgeCheckpoint

All Implemented Interfaces:

Serializable

public class AcknowledgeCheckpoint
extends AbstractCheckpointMessage
implements Serializable

This message is sent from the 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.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
AcknowledgeCheckpoint(JobID jobId, ExecutionAttemptID taskExecutionId, long checkpointId)
AcknowledgeCheckpoint(JobID job, ExecutionAttemptID taskExecutionId, long checkpointId, CheckpointMetrics checkpointMetrics, TaskStateSnapshot subtaskState)

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object o)
CheckpointMetrics	getCheckpointMetrics()
TaskStateSnapshot	getSubtaskState()
int	hashCode()
String	toString()

Methods inherited from class org.apache.flink.runtime.messages.checkpoint.AbstractCheckpointMessage

getCheckpointId, getJob, getTaskExecutionId

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

AcknowledgeCheckpoint

public AcknowledgeCheckpoint(JobID job,
                             ExecutionAttemptID taskExecutionId,
                             long checkpointId,
                             CheckpointMetrics checkpointMetrics,
                             TaskStateSnapshot subtaskState)

AcknowledgeCheckpoint

@VisibleForTesting
public AcknowledgeCheckpoint(JobID jobId,
                                                ExecutionAttemptID taskExecutionId,
                                                long checkpointId)

Method Detail

getSubtaskState

public TaskStateSnapshot getSubtaskState()

getCheckpointMetrics

public CheckpointMetrics getCheckpointMetrics()

equals

public boolean equals(Object o)

Overrides:

equals in class AbstractCheckpointMessage

hashCode

public int hashCode()

Overrides:

hashCode in class AbstractCheckpointMessage

toString

public String toString()

Overrides:

toString in class AbstractCheckpointMessage