Uses of Class
org.apache.flink.api.connector.source.lib.NumberSequenceSource.NumberSequenceSplit

Packages that use NumberSequenceSource.NumberSequenceSplit

Package	Description
org.apache.flink.api.connector.source.lib
org.apache.flink.connector.datagen.source

Uses of NumberSequenceSource.NumberSequenceSplit in org.apache.flink.api.connector.source.lib

Methods in org.apache.flink.api.connector.source.lib that return types with arguments of type NumberSequenceSource.NumberSequenceSplit

Modifier and Type	Method	Description
SplitEnumerator<NumberSequenceSource.NumberSequenceSplit,Collection<NumberSequenceSource.NumberSequenceSplit>>	NumberSequenceSource.createEnumerator(SplitEnumeratorContext<NumberSequenceSource.NumberSequenceSplit> enumContext)
SplitEnumerator<NumberSequenceSource.NumberSequenceSplit,Collection<NumberSequenceSource.NumberSequenceSplit>>	NumberSequenceSource.createEnumerator(SplitEnumeratorContext<NumberSequenceSource.NumberSequenceSplit> enumContext)
SourceReader<Long,NumberSequenceSource.NumberSequenceSplit>	NumberSequenceSource.createReader(SourceReaderContext readerContext)
SimpleVersionedSerializer<Collection<NumberSequenceSource.NumberSequenceSplit>>	NumberSequenceSource.getEnumeratorCheckpointSerializer()
SimpleVersionedSerializer<NumberSequenceSource.NumberSequenceSplit>	NumberSequenceSource.getSplitSerializer()
SplitEnumerator<NumberSequenceSource.NumberSequenceSplit,Collection<NumberSequenceSource.NumberSequenceSplit>>	NumberSequenceSource.restoreEnumerator(SplitEnumeratorContext<NumberSequenceSource.NumberSequenceSplit> enumContext, Collection<NumberSequenceSource.NumberSequenceSplit> checkpoint)
SplitEnumerator<NumberSequenceSource.NumberSequenceSplit,Collection<NumberSequenceSource.NumberSequenceSplit>>	NumberSequenceSource.restoreEnumerator(SplitEnumeratorContext<NumberSequenceSource.NumberSequenceSplit> enumContext, Collection<NumberSequenceSource.NumberSequenceSplit> checkpoint)
protected List<NumberSequenceSource.NumberSequenceSplit>	NumberSequenceSource.splitNumberRange(long from, long to, int numSplits)

Method parameters in org.apache.flink.api.connector.source.lib with type arguments of type NumberSequenceSource.NumberSequenceSplit

Modifier and Type	Method	Description
SplitEnumerator<NumberSequenceSource.NumberSequenceSplit,Collection<NumberSequenceSource.NumberSequenceSplit>>	NumberSequenceSource.createEnumerator(SplitEnumeratorContext<NumberSequenceSource.NumberSequenceSplit> enumContext)
SplitEnumerator<NumberSequenceSource.NumberSequenceSplit,Collection<NumberSequenceSource.NumberSequenceSplit>>	NumberSequenceSource.restoreEnumerator(SplitEnumeratorContext<NumberSequenceSource.NumberSequenceSplit> enumContext, Collection<NumberSequenceSource.NumberSequenceSplit> checkpoint)
SplitEnumerator<NumberSequenceSource.NumberSequenceSplit,Collection<NumberSequenceSource.NumberSequenceSplit>>	NumberSequenceSource.restoreEnumerator(SplitEnumeratorContext<NumberSequenceSource.NumberSequenceSplit> enumContext, Collection<NumberSequenceSource.NumberSequenceSplit> checkpoint)

Uses of NumberSequenceSource.NumberSequenceSplit in org.apache.flink.connector.datagen.source

Methods in org.apache.flink.connector.datagen.source that return types with arguments of type NumberSequenceSource.NumberSequenceSplit

Modifier and Type	Method	Description
SplitEnumerator<NumberSequenceSource.NumberSequenceSplit,Collection<NumberSequenceSource.NumberSequenceSplit>>	DataGeneratorSource.createEnumerator(SplitEnumeratorContext<NumberSequenceSource.NumberSequenceSplit> enumContext)
SplitEnumerator<NumberSequenceSource.NumberSequenceSplit,Collection<NumberSequenceSource.NumberSequenceSplit>>	DataGeneratorSource.createEnumerator(SplitEnumeratorContext<NumberSequenceSource.NumberSequenceSplit> enumContext)
SourceReader<OUT,NumberSequenceSource.NumberSequenceSplit>	DataGeneratorSource.createReader(SourceReaderContext readerContext)
SimpleVersionedSerializer<Collection<NumberSequenceSource.NumberSequenceSplit>>	DataGeneratorSource.getEnumeratorCheckpointSerializer()
SimpleVersionedSerializer<NumberSequenceSource.NumberSequenceSplit>	DataGeneratorSource.getSplitSerializer()
SplitEnumerator<NumberSequenceSource.NumberSequenceSplit,Collection<NumberSequenceSource.NumberSequenceSplit>>	DataGeneratorSource.restoreEnumerator(SplitEnumeratorContext<NumberSequenceSource.NumberSequenceSplit> enumContext, Collection<NumberSequenceSource.NumberSequenceSplit> checkpoint)
SplitEnumerator<NumberSequenceSource.NumberSequenceSplit,Collection<NumberSequenceSource.NumberSequenceSplit>>	DataGeneratorSource.restoreEnumerator(SplitEnumeratorContext<NumberSequenceSource.NumberSequenceSplit> enumContext, Collection<NumberSequenceSource.NumberSequenceSplit> checkpoint)

Method parameters in org.apache.flink.connector.datagen.source with type arguments of type NumberSequenceSource.NumberSequenceSplit

Modifier and Type	Method	Description
SplitEnumerator<NumberSequenceSource.NumberSequenceSplit,Collection<NumberSequenceSource.NumberSequenceSplit>>	DataGeneratorSource.createEnumerator(SplitEnumeratorContext<NumberSequenceSource.NumberSequenceSplit> enumContext)
SplitEnumerator<NumberSequenceSource.NumberSequenceSplit,Collection<NumberSequenceSource.NumberSequenceSplit>>	DataGeneratorSource.restoreEnumerator(SplitEnumeratorContext<NumberSequenceSource.NumberSequenceSplit> enumContext, Collection<NumberSequenceSource.NumberSequenceSplit> checkpoint)
SplitEnumerator<NumberSequenceSource.NumberSequenceSplit,Collection<NumberSequenceSource.NumberSequenceSplit>>	DataGeneratorSource.restoreEnumerator(SplitEnumeratorContext<NumberSequenceSource.NumberSequenceSplit> enumContext, Collection<NumberSequenceSource.NumberSequenceSplit> checkpoint)