Package | Description |
---|---|
org.apache.flink.api.connector.source | |
org.apache.flink.api.connector.source.lib | |
org.apache.flink.api.connector.source.lib.util |
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) |
Modifier and Type | Class and Description |
---|---|
class |
IteratorSourceEnumerator<SplitT extends IteratorSourceSplit<?,?>>
A
SplitEnumerator for iterator sources. |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.