E- The type of the elements returned by the iterator.
@Public public interface IteratorSourceSplit<E,IterT extends Iterator<E>> extends SourceSplit
SourceSplitthat 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.
|Modifier and Type||Method and Description|
Gets the iterator over the elements of this split.
Converts an iterator (that may have returned some elements already) back into a source split.
IteratorSourceSplit<E,IterT> getUpdatedSplitForIterator(IterT iterator)
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.