org.apache.flink.runtime.operators.coordination

Class AcknowledgeCheckpointEvent

java.lang.Object

org.apache.flink.runtime.operators.coordination.AcknowledgeCheckpointEvent

All Implemented Interfaces:

Serializable, OperatorEvent

public class AcknowledgeCheckpointEvent
extends Object
implements OperatorEvent

An OperatorEvent sent from a subtask to its OperatorCoordinator to signal that the checkpoint of an individual task is completed.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
AcknowledgeCheckpointEvent(long checkpointId)

Method Summary

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.flink.runtime.operators.coordination.OperatorEvent

isLossTolerant

Constructor Detail

AcknowledgeCheckpointEvent

public AcknowledgeCheckpointEvent(long checkpointId)