org.apache.flink.runtime.operators.coordination

Interface OperatorEvent

All Superinterfaces:

Serializable

All Known Implementing Classes:

AcknowledgeCheckpointEvent, AddSplitEvent, IsProcessingBacklogEvent, NoMoreSplitsEvent, ReaderRegistrationEvent, ReportedWatermarkEvent, RequestSplitEvent, SourceEventWrapper, WatermarkAlignmentEvent

public interface OperatorEvent
extends Serializable

Root interface for all events sent between OperatorCoordinator and an OperatorEventHandler.

Method Summary

Modifier and Type	Method and Description
default boolean	isLossTolerant()

Method Detail

isLossTolerant

default boolean isLossTolerant()

Returns:

true if event is optional and an occasional loss or inability to deliver that event doesn't affect the job's correctness.