Package org.apache.flink.runtime.operators.coordination

Interface OperatorEvent

All Superinterfaces:

Serializable

All Known Implementing Classes:

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

public interface OperatorEvent
extends Serializable

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