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.

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

Modifier and Type	Method	Description
static <SplitT extends SourceSplit> ReaderInfo	ReaderInfo.createReaderInfo(int subtaskId, String location, List<SplitT> splits)
<SplitT extends SourceSplit> List<SplitT>	ReaderInfo.getReportedSplitsOnRegistration()

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	GatedRateLimiter<Split extends SourceSplit>	An implementation of RateLimiter that completes defined number of futures in-between the external notification events.
class	GuavaRateLimiter<Split extends SourceSplit>	An implementation of RateLimiter based on Guava's RateLimiter.
class	NoOpRateLimiter<Split extends SourceSplit>	A convenience implementation of RateLimiter that does not throttle requests.
class	RateLimitedSourceReader<E,SplitT extends SourceSplit>	Wraps the actual SourceReader and rate limits its data emission.
interface	RateLimiter<SplitT extends SourceSplit>	The interface to rate limit execution of methods.
interface	RateLimiterStrategy<SplitT extends SourceSplit>	A factory for RateLimiters which apply rate-limiting to a source sub-task.