Modifier and Type | Method and Description |
---|---|
SplitEnumerator<SplitT,EnumChkT> |
Source.createEnumerator(SplitEnumeratorContext<SplitT> enumContext)
Creates a new SplitEnumerator for this source, starting a new input.
|
SplitEnumerator<SplitT,EnumChkT> |
Source.restoreEnumerator(SplitEnumeratorContext<SplitT> enumContext,
EnumChkT checkpoint)
Restores an enumerator from a checkpoint.
|
Modifier and Type | Method and 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) |
Constructor and Description |
---|
IteratorSourceEnumerator(SplitEnumeratorContext<SplitT> context,
Collection<SplitT> splits) |
Modifier and Type | Class and Description |
---|---|
class |
SourceCoordinatorContext<SplitT extends SourceSplit>
A context class for the
OperatorCoordinator . |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.