Interface SupportsIntermediateNoMoreSplits


  • @Internal
    public interface SupportsIntermediateNoMoreSplits
    A decorative interface of 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.

    • 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.