Uses of Interface
org.apache.flink.api.connector.source.SourceSplit

Packages that use SourceSplit

Package	Description
org.apache.flink.api.connector.source
org.apache.flink.api.connector.source.lib
org.apache.flink.api.connector.source.lib.util
org.apache.flink.api.connector.source.util.ratelimit

Uses of SourceSplit in org.apache.flink.api.connector.source

Classes in org.apache.flink.api.connector.source with type parameters of type SourceSplit

Modifier and Type	Interface	Description
interface	ExternallyInducedSourceReader<T,SplitT extends SourceSplit>	Sources that implement this interface delay checkpoints when receiving a trigger message from the checkpoint coordinator to the point when their input data/events indicate that a checkpoint should be triggered.
interface	Source<T,SplitT extends SourceSplit,EnumChkT>	The interface for Source.
interface	SourceReader<T,SplitT extends SourceSplit>	The interface for a source reader which is responsible for reading the records from the source splits assigned by SplitEnumerator.
interface	SourceReaderFactory<T,SplitT extends SourceSplit>	A factory for creating source reader instances.
interface	SplitEnumerator<SplitT extends SourceSplit,CheckpointT>	The interface for a split enumerator responsible for discovering the source splits, and assigning them to the SourceReader.
interface	SplitEnumeratorContext<SplitT extends SourceSplit>	A context class for the SplitEnumerator.
class	SplitsAssignment<SplitT extends SourceSplit>	A class containing the splits assignment to the source readers.

Uses of SourceSplit in org.apache.flink.api.connector.source.lib

Classes in org.apache.flink.api.connector.source.lib that implement SourceSplit

Modifier and Type	Class	Description
static class	NumberSequenceSource.NumberSequenceSplit	A split of the source, representing a number sub-sequence.

Uses of SourceSplit in org.apache.flink.api.connector.source.lib.util

Subinterfaces of SourceSplit in org.apache.flink.api.connector.source.lib.util

Modifier and Type	Interface	Description
interface	IteratorSourceSplit<E,IterT extends Iterator<E>>	A SourceSplit that represents a sequence of elements captured in an iterator.

Uses of SourceSplit in org.apache.flink.api.connector.source.util.ratelimit

Classes in org.apache.flink.api.connector.source.util.ratelimit with type parameters of type SourceSplit

Modifier and Type	Class	Description
class	RateLimitedSourceReader<E,SplitT extends SourceSplit>	Wraps the actual SourceReader and rate limits its data emission.