Uses of Interface
org.apache.flink.api.connector.source.SplitEnumerator
-
Packages that use SplitEnumerator Package Description org.apache.flink.api.connector.source org.apache.flink.api.connector.source.lib org.apache.flink.api.connector.source.lib.util -
-
Uses of SplitEnumerator in org.apache.flink.api.connector.source
Methods in org.apache.flink.api.connector.source that return SplitEnumerator Modifier and Type Method 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. -
Uses of SplitEnumerator in org.apache.flink.api.connector.source.lib
Methods in org.apache.flink.api.connector.source.lib that return SplitEnumerator 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) -
Uses of SplitEnumerator in org.apache.flink.api.connector.source.lib.util
Classes in org.apache.flink.api.connector.source.lib.util that implement SplitEnumerator Modifier and Type Class Description classIteratorSourceEnumerator<SplitT extends IteratorSourceSplit<?,?>>ASplitEnumeratorfor iterator sources.
-