org.apache.paimon.flink.source

Class NumberSequenceRowSource.NumberSequenceSplit

java.lang.Object

org.apache.paimon.flink.source.NumberSequenceRowSource.NumberSequenceSplit

All Implemented Interfaces:

org.apache.flink.api.connector.source.lib.util.IteratorSourceSplit<org.apache.flink.table.data.RowData,org.apache.paimon.flink.source.NumberSequenceRowSource.NumberSequenceIterator>, org.apache.flink.api.connector.source.SourceSplit

Enclosing class:

NumberSequenceRowSource

public static class NumberSequenceRowSource.NumberSequenceSplit
extends Object
implements org.apache.flink.api.connector.source.lib.util.IteratorSourceSplit<org.apache.flink.table.data.RowData,org.apache.paimon.flink.source.NumberSequenceRowSource.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()
org.apache.paimon.flink.source.NumberSequenceRowSource.NumberSequenceIterator	getIterator()
org.apache.flink.api.connector.source.lib.util.IteratorSourceSplit<org.apache.flink.table.data.RowData,org.apache.paimon.flink.source.NumberSequenceRowSource.NumberSequenceIterator>	getUpdatedSplitForIterator(org.apache.paimon.flink.source.NumberSequenceRowSource.NumberSequenceIterator iterator)
String	splitId()
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()

Specified by:

splitId in interface org.apache.flink.api.connector.source.SourceSplit

from

public long from()

to

public long to()

getIterator

public org.apache.paimon.flink.source.NumberSequenceRowSource.NumberSequenceIterator getIterator()

Specified by:

getIterator in interface org.apache.flink.api.connector.source.lib.util.IteratorSourceSplit<org.apache.flink.table.data.RowData,org.apache.paimon.flink.source.NumberSequenceRowSource.NumberSequenceIterator>

getUpdatedSplitForIterator

public org.apache.flink.api.connector.source.lib.util.IteratorSourceSplit<org.apache.flink.table.data.RowData,org.apache.paimon.flink.source.NumberSequenceRowSource.NumberSequenceIterator> getUpdatedSplitForIterator(org.apache.paimon.flink.source.NumberSequenceRowSource.NumberSequenceIterator iterator)

Specified by:

getUpdatedSplitForIterator in interface org.apache.flink.api.connector.source.lib.util.IteratorSourceSplit<org.apache.flink.table.data.RowData,org.apache.paimon.flink.source.NumberSequenceRowSource.NumberSequenceIterator>

toString

public String toString()

Overrides:

toString in class Object