org.apache.flink.runtime.messages.checkpoint

Class TriggerCheckpoint

java.lang.Object

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

org.apache.flink.runtime.messages.checkpoint.TriggerCheckpoint

All Implemented Interfaces:

Serializable

public class TriggerCheckpoint
extends AbstractCheckpointMessage
implements Serializable

This message is sent from the JobManager to the TaskManager to tell a certain task to trigger its checkpoint.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
TriggerCheckpoint(JobID job, ExecutionAttemptID taskExecutionId, long checkpointId, long timestamp, CheckpointOptions checkpointOptions)

Method Summary

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

TriggerCheckpoint

public TriggerCheckpoint(JobID job,
                         ExecutionAttemptID taskExecutionId,
                         long checkpointId,
                         long timestamp,
                         CheckpointOptions checkpointOptions)

Method Detail

getTimestamp

public long getTimestamp()

getCheckpointOptions

public CheckpointOptions getCheckpointOptions()

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