Uses of Interface
org.apache.flink.api.connector.source.lib.util.IteratorSourceSplit
-
Packages that use IteratorSourceSplit Package Description org.apache.flink.api.connector.source.lib org.apache.flink.api.connector.source.lib.util -
-
Uses of IteratorSourceSplit in org.apache.flink.api.connector.source.lib
Classes in org.apache.flink.api.connector.source.lib that implement IteratorSourceSplit Modifier and Type Class Description static classNumberSequenceSource.NumberSequenceSplitA split of the source, representing a number sub-sequence.Methods in org.apache.flink.api.connector.source.lib that return IteratorSourceSplit Modifier and Type Method Description IteratorSourceSplit<Long,NumberSequenceIterator>NumberSequenceSource.NumberSequenceSplit. getUpdatedSplitForIterator(NumberSequenceIterator iterator) -
Uses of IteratorSourceSplit in org.apache.flink.api.connector.source.lib.util
Classes in org.apache.flink.api.connector.source.lib.util with type parameters of type IteratorSourceSplit Modifier and Type Class Description classIteratorSourceEnumerator<SplitT extends IteratorSourceSplit<?,?>>ASplitEnumeratorfor iterator sources.classIteratorSourceReader<E,IterT extends Iterator<E>,SplitT extends IteratorSourceSplit<E,IterT>>ASourceReaderthat returns the values of an iterator, supplied via anIteratorSourceSplit.classIteratorSourceReaderBase<E,O,IterT extends Iterator<E>,SplitT extends IteratorSourceSplit<E,IterT>>ASourceReaderthat returns the values of an iterator, supplied via anIteratorSourceSplit.Fields in org.apache.flink.api.connector.source.lib.util declared as IteratorSourceSplit Modifier and Type Field Description protected SplitTIteratorSourceReaderBase. currentSplitThe split whose data we return.Methods in org.apache.flink.api.connector.source.lib.util that return IteratorSourceSplit Modifier and Type Method Description IteratorSourceSplit<E,IterT>IteratorSourceSplit. getUpdatedSplitForIterator(IterT iterator)Converts an iterator (that may have returned some elements already) back into a source split.
-