Package org.apache.flink.api.connector.source.lib.util
-
Interface Summary Interface Description IteratorSourceSplit<E,IterT extends Iterator<E>> ASourceSplitthat represents a sequence of elements captured in an iterator. -
Class Summary Class Description IteratorSourceEnumerator<SplitT extends IteratorSourceSplit<?,?>> ASplitEnumeratorfor iterator sources.IteratorSourceReader<E,IterT extends Iterator<E>,SplitT extends IteratorSourceSplit<E,IterT>> ASourceReaderthat returns the values of an iterator, supplied via anIteratorSourceSplit.IteratorSourceReaderBase<E,O,IterT extends Iterator<E>,SplitT extends IteratorSourceSplit<E,IterT>> ASourceReaderthat returns the values of an iterator, supplied via anIteratorSourceSplit.