Uses of Class
org.apache.paimon.flink.source.NumberSequenceRowSource.NumberSequenceSplit

Packages that use NumberSequenceRowSource.NumberSequenceSplit

Package	Description
org.apache.paimon.flink.source

Uses of NumberSequenceRowSource.NumberSequenceSplit in org.apache.paimon.flink.source

Methods in org.apache.paimon.flink.source that return types with arguments of type NumberSequenceRowSource.NumberSequenceSplit

Modifier and Type	Method and Description
org.apache.flink.api.connector.source.SplitEnumerator<NumberSequenceRowSource.NumberSequenceSplit,Collection<NumberSequenceRowSource.NumberSequenceSplit>>	NumberSequenceRowSource.createEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<NumberSequenceRowSource.NumberSequenceSplit> enumContext)
org.apache.flink.api.connector.source.SplitEnumerator<NumberSequenceRowSource.NumberSequenceSplit,Collection<NumberSequenceRowSource.NumberSequenceSplit>>	NumberSequenceRowSource.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>	NumberSequenceRowSource.createReader(org.apache.flink.api.connector.source.SourceReaderContext readerContext)
org.apache.flink.core.io.SimpleVersionedSerializer<Collection<NumberSequenceRowSource.NumberSequenceSplit>>	NumberSequenceRowSource.getEnumeratorCheckpointSerializer()
org.apache.flink.core.io.SimpleVersionedSerializer<NumberSequenceRowSource.NumberSequenceSplit>	NumberSequenceRowSource.getSplitSerializer()
org.apache.flink.api.connector.source.SplitEnumerator<NumberSequenceRowSource.NumberSequenceSplit,Collection<NumberSequenceRowSource.NumberSequenceSplit>>	NumberSequenceRowSource.restoreEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<NumberSequenceRowSource.NumberSequenceSplit> enumContext, Collection<NumberSequenceRowSource.NumberSequenceSplit> checkpoint)
org.apache.flink.api.connector.source.SplitEnumerator<NumberSequenceRowSource.NumberSequenceSplit,Collection<NumberSequenceRowSource.NumberSequenceSplit>>	NumberSequenceRowSource.restoreEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<NumberSequenceRowSource.NumberSequenceSplit> enumContext, Collection<NumberSequenceRowSource.NumberSequenceSplit> checkpoint)
protected List<NumberSequenceRowSource.NumberSequenceSplit>	NumberSequenceRowSource.splitNumberRange(long from, long to, int numSplits)

Method parameters in org.apache.paimon.flink.source with type arguments of type NumberSequenceRowSource.NumberSequenceSplit

Modifier and Type	Method and Description
org.apache.flink.api.connector.source.SplitEnumerator<NumberSequenceRowSource.NumberSequenceSplit,Collection<NumberSequenceRowSource.NumberSequenceSplit>>	NumberSequenceRowSource.createEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<NumberSequenceRowSource.NumberSequenceSplit> enumContext)
org.apache.flink.api.connector.source.SplitEnumerator<NumberSequenceRowSource.NumberSequenceSplit,Collection<NumberSequenceRowSource.NumberSequenceSplit>>	NumberSequenceRowSource.restoreEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<NumberSequenceRowSource.NumberSequenceSplit> enumContext, Collection<NumberSequenceRowSource.NumberSequenceSplit> checkpoint)
org.apache.flink.api.connector.source.SplitEnumerator<NumberSequenceRowSource.NumberSequenceSplit,Collection<NumberSequenceRowSource.NumberSequenceSplit>>	NumberSequenceRowSource.restoreEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<NumberSequenceRowSource.NumberSequenceSplit> enumContext, Collection<NumberSequenceRowSource.NumberSequenceSplit> checkpoint)