org.apache.flink.runtime.messages.checkpoint

Class NotifyCheckpointComplete

java.lang.Object

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

org.apache.flink.runtime.messages.checkpoint.NotifyCheckpointComplete

All Implemented Interfaces:

Serializable

public class NotifyCheckpointComplete
extends AbstractCheckpointMessage
implements Serializable

This message is sent from the JobManager to the TaskManager to tell a task that the checkpoint has been confirmed and that the task can commit the checkpoint to the outside world.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
NotifyCheckpointComplete(JobID job, ExecutionAttemptID taskExecutionId, long checkpointId, long timestamp)

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object o)
long	getTimestamp()
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

NotifyCheckpointComplete

public NotifyCheckpointComplete(JobID job,
                                ExecutionAttemptID taskExecutionId,
                                long checkpointId,
                                long timestamp)

Method Detail

getTimestamp

public long getTimestamp()

hashCode

public int hashCode()

Overrides:

hashCode in class AbstractCheckpointMessage

equals

public boolean equals(Object o)

Overrides:

equals in class AbstractCheckpointMessage

toString

public String toString()

Overrides:

toString in class AbstractCheckpointMessage