Package org.apache.flink.api.connector.source.lib.util

Interface IteratorSourceSplit<E,​IterT extends Iterator<E>>

  • Type Parameters:
    E - The type of the elements returned by the iterator.
    All Superinterfaces:
    SourceSplit
    All Known Implementing Classes:
    NumberSequenceSource.NumberSequenceSplit
    @Public
public interface IteratorSourceSplit<E,​IterT extends Iterator<E>>
extends SourceSplit
    A SourceSplit that represents a sequence of elements captured in an iterator. The split produces the iterator and converts the iterator back to a new split during checkpointing.

    • Method Detail

      • getIterator

        IterT getIterator()
        Gets the iterator over the elements of this split.

      • getUpdatedSplitForIterator

        IteratorSourceSplit<E,​IterT> getUpdatedSplitForIterator​(IterT iterator)
        Converts an iterator (that may have returned some elements already) back into a source split.