org.apache.flink.api.connector.source.lib

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 and Description
NumberSequenceSplit(String splitId, long from, long to)

Method Summary

Modifier and Type	Method and Description
long	from()
NumberSequenceIterator	getIterator() 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.
String	splitId() Get the split id of this source split.
long	to()
String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

NumberSequenceSplit

public NumberSequenceSplit(String splitId,
                           long from,
                           long to)

Method Detail

splitId

public String splitId()

Description copied from interface: SourceSplit

Get the split id of this source split.

Specified by:

splitId in interface SourceSplit

Returns:

id of this source split.

from

public long from()

to

public long to()

getIterator

public NumberSequenceIterator getIterator()

Description copied from interface: IteratorSourceSplit

Gets the iterator over the elements of this split.

Specified by:

getIterator in interface IteratorSourceSplit<Long,NumberSequenceIterator>

getUpdatedSplitForIterator

public IteratorSourceSplit<Long,NumberSequenceIterator> getUpdatedSplitForIterator(NumberSequenceIterator iterator)

Description copied from interface: IteratorSourceSplit

Converts an iterator (that may have returned some elements already) back into a source split.

Specified by:

getUpdatedSplitForIterator in interface IteratorSourceSplit<Long,NumberSequenceIterator>

toString

public String toString()

Overrides:

toString in class Object