Class NumberSequenceSource.NumberSequenceSplit
- java.lang.Object
-
- org.apache.flink.api.connector.source.lib.NumberSequenceSource.NumberSequenceSplit
-
- All Implemented Interfaces:
IteratorSourceSplit<Long,NumberSequenceIterator>,SourceSplit
- Enclosing class:
- NumberSequenceSource
public static class NumberSequenceSource.NumberSequenceSplit extends Object implements IteratorSourceSplit<Long,NumberSequenceIterator>
A split of the source, representing a number sub-sequence.
-
-
Constructor Summary
Constructors Constructor Description NumberSequenceSplit(String splitId, long from, long to)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description longfrom()NumberSequenceIteratorgetIterator()Gets the iterator over the elements of this split.IteratorSourceSplit<Long,NumberSequenceIterator>getUpdatedSplitForIterator(NumberSequenceIterator iterator)Converts an iterator (that may have returned some elements already) back into a source split.StringsplitId()Get the split id of this source split.longto()StringtoString()
-
-
-
Constructor Detail
-
NumberSequenceSplit
public NumberSequenceSplit(String splitId, long from, long to)
-
-
Method Detail
-
splitId
public String splitId()
Description copied from interface:SourceSplitGet the split id of this source split.- Specified by:
splitIdin interfaceSourceSplit- Returns:
- id of this source split.
-
from
public long from()
-
to
public long to()
-
getIterator
public NumberSequenceIterator getIterator()
Description copied from interface:IteratorSourceSplitGets the iterator over the elements of this split.- Specified by:
getIteratorin interfaceIteratorSourceSplit<Long,NumberSequenceIterator>
-
getUpdatedSplitForIterator
public IteratorSourceSplit<Long,NumberSequenceIterator> getUpdatedSplitForIterator(NumberSequenceIterator iterator)
Description copied from interface:IteratorSourceSplitConverts an iterator (that may have returned some elements already) back into a source split.- Specified by:
getUpdatedSplitForIteratorin interfaceIteratorSourceSplit<Long,NumberSequenceIterator>
-
-