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

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)