Interface SupportsIntermediateNoMoreSplits
-
@Internal public interface SupportsIntermediateNoMoreSplitsA decorative interface ofSplitEnumeratorContextwhich allows to handle intermediate NoMoreSplits.The split enumerator must implement this interface if it needs to deal with NoMoreSplits event in cases of a subtask can have multiple child sources. e.g. hybrid source.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description voidsignalIntermediateNoMoreSplits(int subtask)Signals a subtask that it will not receive split for current source, but it will receive split for next sources.
-
-
-
Method Detail
-
signalIntermediateNoMoreSplits
void signalIntermediateNoMoreSplits(int subtask)
Signals a subtask that it will not receive split for current source, but it will receive split for next sources. A common scenario is HybridSource. This indicates that task not truly read finished.- Parameters:
subtask- The index of the operator's parallel subtask that shall be signaled it will receive splits later.
-
-