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 Summary

Modifier and Type	Method and Description
IterT	getIterator() Gets the iterator over the elements of this split.
IteratorSourceSplit<E,IterT>	getUpdatedSplitForIterator(IterT iterator) Converts an iterator (that may have returned some elements already) back into a source split.

Methods inherited from interface org.apache.flink.api.connector.source.SourceSplit

splitId

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.