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

Class IteratorSourceReader<E,​IterT extends Iterator<E>,​SplitT extends IteratorSourceSplit<E,​IterT>>

  • Type Parameters:
    E - The type of events returned by the reader.
    IterT - The type of the iterator that produces the events. This type exists to make the conversion between iterator and IteratorSourceSplit type safe.
    SplitT - The concrete type of the IteratorSourceSplit that creates and converts the iterator that produces this reader's elements.
    All Implemented Interfaces:
    AutoCloseable, CheckpointListener, SourceReader<E,​SplitT>
    @Public
public class IteratorSourceReader<E,​IterT extends Iterator<E>,​SplitT extends IteratorSourceSplit<E,​IterT>>
extends IteratorSourceReaderBase<E,​E,​IterT,​SplitT>
    A SourceReader that returns the values of an iterator, supplied via an IteratorSourceSplit.

    The IteratorSourceSplit is also responsible for taking the current iterator and turning it back into a split for checkpointing.