Class NoMoreSplitsEvent
- java.lang.Object
-
- org.apache.flink.runtime.source.event.NoMoreSplitsEvent
-
- All Implemented Interfaces:
Serializable
,OperatorEvent
public class NoMoreSplitsEvent extends Object implements OperatorEvent
A source event sent from the SplitEnumerator to the SourceReader to indicate that no more splits will be assigned to the source reader anymore. So once the SplitReader finishes reading the currently assigned splits, they can exit.- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description NoMoreSplitsEvent()
-