Uses of Interface
org.apache.flink.api.connector.source.SplitEnumeratorContext
-
Packages that use SplitEnumeratorContext 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 SplitEnumeratorContext in org.apache.flink.api.connector.source
Methods in org.apache.flink.api.connector.source with parameters of type SplitEnumeratorContext 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 SplitEnumeratorContext in org.apache.flink.api.connector.source.lib
Methods in org.apache.flink.api.connector.source.lib with parameters of type SplitEnumeratorContext 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 SplitEnumeratorContext in org.apache.flink.api.connector.source.lib.util
Constructors in org.apache.flink.api.connector.source.lib.util with parameters of type SplitEnumeratorContext Constructor Description IteratorSourceEnumerator(SplitEnumeratorContext<SplitT> context, Collection<SplitT> splits)
-