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) |