Uses of Class
org.apache.flink.runtime.messages.checkpoint.AbstractCheckpointMessage
-
Packages that use AbstractCheckpointMessage Package Description org.apache.flink.runtime.messages.checkpoint This package contains the messages that are sent betweenJobMaster
andTaskExecutor
to coordinate the checkpoint snapshots of the distributed dataflow. -
-
Uses of AbstractCheckpointMessage in org.apache.flink.runtime.messages.checkpoint
Subclasses of AbstractCheckpointMessage in org.apache.flink.runtime.messages.checkpoint Modifier and Type Class Description class
AcknowledgeCheckpoint
This message is sent from theTaskExecutor
to theJobMaster
to signal that the checkpoint of an individual task is completed.class
DeclineCheckpoint
This message is sent from theTaskExecutor
to theJobMaster
to tell the checkpoint coordinator that a checkpoint request could not be heeded.
-