@Internal public interface SupportsIntermediateNoMoreSplits
SplitEnumeratorContext
which 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.
Modifier and Type | Method and Description |
---|---|
void |
signalIntermediateNoMoreSplits(int subtask)
Signals a subtask that it will not receive split for current source, but it will receive
split for next sources.
|
void signalIntermediateNoMoreSplits(int subtask)
subtask
- The index of the operator's parallel subtask that shall be signaled it will
receive splits later.Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.