org.apache.paimon.flink.source

Class NumberSequenceRowSource

java.lang.Object

org.apache.paimon.flink.source.NumberSequenceRowSource

All Implemented Interfaces:

Serializable, org.apache.flink.api.connector.source.Source<org.apache.flink.table.data.RowData,NumberSequenceRowSource.NumberSequenceSplit,Collection<NumberSequenceRowSource.NumberSequenceSplit>>, org.apache.flink.api.connector.source.SourceReaderFactory<org.apache.flink.table.data.RowData,NumberSequenceRowSource.NumberSequenceSplit>, org.apache.flink.api.java.typeutils.ResultTypeQueryable<org.apache.flink.table.data.RowData>

public class NumberSequenceRowSource
extends Object
implements org.apache.flink.api.connector.source.Source<org.apache.flink.table.data.RowData,NumberSequenceRowSource.NumberSequenceSplit,Collection<NumberSequenceRowSource.NumberSequenceSplit>>, org.apache.flink.api.java.typeutils.ResultTypeQueryable<org.apache.flink.table.data.RowData>

A data source that produces a sequence of numbers (longs) to RowData.

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	NumberSequenceRowSource.NumberSequenceSplit A split of the source, representing a number sub-sequence.

Constructor Summary

Constructors

Constructor and Description
NumberSequenceRowSource(long from, long to) Creates a new NumberSequenceSource that produces parallel sequences covering the range from to to (both boundaries are inclusive).

Method Summary

Modifier and Type	Method and Description
org.apache.flink.api.connector.source.SplitEnumerator<NumberSequenceRowSource.NumberSequenceSplit,Collection<NumberSequenceRowSource.NumberSequenceSplit>>	createEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<NumberSequenceRowSource.NumberSequenceSplit> enumContext)
org.apache.flink.api.connector.source.SourceReader<org.apache.flink.table.data.RowData,NumberSequenceRowSource.NumberSequenceSplit>	createReader(org.apache.flink.api.connector.source.SourceReaderContext readerContext)
org.apache.flink.api.connector.source.Boundedness	getBoundedness()
org.apache.flink.core.io.SimpleVersionedSerializer<Collection<NumberSequenceRowSource.NumberSequenceSplit>>	getEnumeratorCheckpointSerializer()
long	getFrom()
org.apache.flink.api.common.typeinfo.TypeInformation<org.apache.flink.table.data.RowData>	getProducedType()
org.apache.flink.core.io.SimpleVersionedSerializer<NumberSequenceRowSource.NumberSequenceSplit>	getSplitSerializer()
long	getTo()
org.apache.flink.api.connector.source.SplitEnumerator<NumberSequenceRowSource.NumberSequenceSplit,Collection<NumberSequenceRowSource.NumberSequenceSplit>>	restoreEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<NumberSequenceRowSource.NumberSequenceSplit> enumContext, Collection<NumberSequenceRowSource.NumberSequenceSplit> checkpoint)
protected List<NumberSequenceRowSource.NumberSequenceSplit>	splitNumberRange(long from, long to, int numSplits)

Methods inherited from class java.lang.Object

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

Constructor Detail

NumberSequenceRowSource

public NumberSequenceRowSource(long from,
                               long to)

Creates a new NumberSequenceSource that produces parallel sequences covering the range from to to (both boundaries are inclusive).

Method Detail

getFrom

public long getFrom()

getTo

public long getTo()

getProducedType

public org.apache.flink.api.common.typeinfo.TypeInformation<org.apache.flink.table.data.RowData> getProducedType()

Specified by:

getProducedType in interface org.apache.flink.api.java.typeutils.ResultTypeQueryable<org.apache.flink.table.data.RowData>

getBoundedness

public org.apache.flink.api.connector.source.Boundedness getBoundedness()

Specified by:

getBoundedness in interface org.apache.flink.api.connector.source.Source<org.apache.flink.table.data.RowData,NumberSequenceRowSource.NumberSequenceSplit,Collection<NumberSequenceRowSource.NumberSequenceSplit>>

createReader

public org.apache.flink.api.connector.source.SourceReader<org.apache.flink.table.data.RowData,NumberSequenceRowSource.NumberSequenceSplit> createReader(org.apache.flink.api.connector.source.SourceReaderContext readerContext)

Specified by:

createReader in interface org.apache.flink.api.connector.source.SourceReaderFactory<org.apache.flink.table.data.RowData,NumberSequenceRowSource.NumberSequenceSplit>

createEnumerator

public org.apache.flink.api.connector.source.SplitEnumerator<NumberSequenceRowSource.NumberSequenceSplit,Collection<NumberSequenceRowSource.NumberSequenceSplit>> createEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<NumberSequenceRowSource.NumberSequenceSplit> enumContext)

Specified by:

createEnumerator in interface org.apache.flink.api.connector.source.Source<org.apache.flink.table.data.RowData,NumberSequenceRowSource.NumberSequenceSplit,Collection<NumberSequenceRowSource.NumberSequenceSplit>>

restoreEnumerator

public org.apache.flink.api.connector.source.SplitEnumerator<NumberSequenceRowSource.NumberSequenceSplit,Collection<NumberSequenceRowSource.NumberSequenceSplit>> restoreEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<NumberSequenceRowSource.NumberSequenceSplit> enumContext,
                                                                                                                                                                                    Collection<NumberSequenceRowSource.NumberSequenceSplit> checkpoint)

Specified by:

restoreEnumerator in interface org.apache.flink.api.connector.source.Source<org.apache.flink.table.data.RowData,NumberSequenceRowSource.NumberSequenceSplit,Collection<NumberSequenceRowSource.NumberSequenceSplit>>

getSplitSerializer

public org.apache.flink.core.io.SimpleVersionedSerializer<NumberSequenceRowSource.NumberSequenceSplit> getSplitSerializer()

Specified by:

getSplitSerializer in interface org.apache.flink.api.connector.source.Source<org.apache.flink.table.data.RowData,NumberSequenceRowSource.NumberSequenceSplit,Collection<NumberSequenceRowSource.NumberSequenceSplit>>

getEnumeratorCheckpointSerializer

public org.apache.flink.core.io.SimpleVersionedSerializer<Collection<NumberSequenceRowSource.NumberSequenceSplit>> getEnumeratorCheckpointSerializer()

Specified by:

getEnumeratorCheckpointSerializer in interface org.apache.flink.api.connector.source.Source<org.apache.flink.table.data.RowData,NumberSequenceRowSource.NumberSequenceSplit,Collection<NumberSequenceRowSource.NumberSequenceSplit>>

splitNumberRange

protected List<NumberSequenceRowSource.NumberSequenceSplit> splitNumberRange(long from,
                                                                             long to,
                                                                             int numSplits)