Uses of Package
org.apache.flink.api.connector.source

Packages that use org.apache.flink.api.connector.source

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

Classes in org.apache.flink.api.connector.source used by org.apache.flink.api.connector.source

Class	Description
Boundedness	The boundedness of a stream.
ReaderInfo	A container class hosting the information of a SourceReader.
ReaderOutput	The interface provided by the Flink runtime to the SourceReader to emit records, and optionally watermarks, to downstream operators for message processing.
SourceEvent	An base class for the events passed between the SourceReaders and Enumerators.
SourceOutput	The SourceOutput is the gateway for a SourceReader) to emit the produced records and watermarks.
SourceReader	The interface for a source reader which is responsible for reading the records from the source splits assigned by SplitEnumerator.
SourceReaderContext	The interface that exposes some context from runtime to the SourceReader.
SourceReaderFactory	A factory for creating source reader instances.
SourceSplit	An interface for all the Split types to extend.
SplitEnumerator	The interface for a split enumerator responsible for discovering the source splits, and assigning them to the SourceReader.
SplitEnumeratorContext	A context class for the SplitEnumerator.
SplitsAssignment	A class containing the splits assignment to the source readers.

Classes in org.apache.flink.api.connector.source used by org.apache.flink.api.connector.source.lib

Class	Description
Boundedness	The boundedness of a stream.
Source	The interface for Source.
SourceReader	The interface for a source reader which is responsible for reading the records from the source splits assigned by SplitEnumerator.
SourceReaderContext	The interface that exposes some context from runtime to the SourceReader.
SourceReaderFactory	A factory for creating source reader instances.
SourceSplit	An interface for all the Split types to extend.
SplitEnumerator	The interface for a split enumerator responsible for discovering the source splits, and assigning them to the SourceReader.
SplitEnumeratorContext	A context class for the SplitEnumerator.

Classes in org.apache.flink.api.connector.source used by org.apache.flink.api.connector.source.lib.util

Class	Description
ReaderOutput	The interface provided by the Flink runtime to the SourceReader to emit records, and optionally watermarks, to downstream operators for message processing.
SourceReader	The interface for a source reader which is responsible for reading the records from the source splits assigned by SplitEnumerator.
SourceReaderContext	The interface that exposes some context from runtime to the SourceReader.
SourceSplit	An interface for all the Split types to extend.
SplitEnumerator	The interface for a split enumerator responsible for discovering the source splits, and assigning them to the SourceReader.
SplitEnumeratorContext	A context class for the SplitEnumerator.

Classes in org.apache.flink.api.connector.source used by org.apache.flink.api.connector.source.util.ratelimit

Class	Description
ReaderOutput	The interface provided by the Flink runtime to the SourceReader to emit records, and optionally watermarks, to downstream operators for message processing.
SourceReader	The interface for a source reader which is responsible for reading the records from the source splits assigned by SplitEnumerator.
SourceSplit	An interface for all the Split types to extend.