Class Hierarchy
- java.lang.Object
- org.apache.flink.runtime.source.event.AddSplitEvent<SplitT> (implements org.apache.flink.runtime.operators.coordination.OperatorEvent)
- org.apache.flink.runtime.source.event.IsProcessingBacklogEvent (implements org.apache.flink.runtime.operators.coordination.OperatorEvent)
- org.apache.flink.runtime.source.event.NoMoreSplitsEvent (implements org.apache.flink.runtime.operators.coordination.OperatorEvent)
- org.apache.flink.runtime.source.event.ReaderRegistrationEvent (implements org.apache.flink.runtime.operators.coordination.OperatorEvent)
- org.apache.flink.runtime.source.event.ReportedWatermarkEvent (implements org.apache.flink.runtime.operators.coordination.OperatorEvent)
- org.apache.flink.runtime.source.event.RequestSplitEvent (implements org.apache.flink.runtime.operators.coordination.OperatorEvent)
- org.apache.flink.runtime.source.event.SourceEventWrapper (implements org.apache.flink.runtime.operators.coordination.OperatorEvent)
- org.apache.flink.runtime.source.event.WatermarkAlignmentEvent (implements org.apache.flink.runtime.operators.coordination.OperatorEvent)