org.apache.flink.runtime.source.event

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 and Description
NoMoreSplitsEvent()

Method Summary

Modifier and Type	Method and Description
String	toString()

Methods inherited from class java.lang.Object

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

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

isLossTolerant

Constructor Detail

NoMoreSplitsEvent

public NoMoreSplitsEvent()

Method Detail

toString

public String toString()

Overrides:

toString in class Object