Uses of Package
org.apache.flink.connector.base.source.reader.fetcher

Packages that use org.apache.flink.connector.base.source.reader.fetcher

Package	Description
org.apache.flink.connector.base.source.reader
org.apache.flink.connector.base.source.reader.fetcher
org.apache.flink.connector.kafka.source.reader.fetcher
org.apache.flink.connector.pulsar.source.reader.fetcher

Classes in org.apache.flink.connector.base.source.reader.fetcher used by org.apache.flink.connector.base.source.reader

Class and Description
SingleThreadFetcherManager A Fetcher Manager with a single fetching thread (I/O thread) that handles all splits concurrently.
SplitFetcherManager A class responsible for starting the SplitFetcher and manage the life cycles of them.

Classes in org.apache.flink.connector.base.source.reader.fetcher used by org.apache.flink.connector.base.source.reader.fetcher

Class and Description
SplitFetcher The internal fetcher runnable responsible for polling message from the external system.
SplitFetcherManager A class responsible for starting the SplitFetcher and manage the life cycles of them.
SplitFetcherTask An interface similar to Runnable but allows throwing exceptions and wakeup.

Classes in org.apache.flink.connector.base.source.reader.fetcher used by org.apache.flink.connector.kafka.source.reader.fetcher

Class and Description
SingleThreadFetcherManager A Fetcher Manager with a single fetching thread (I/O thread) that handles all splits concurrently.
SplitFetcherManager A class responsible for starting the SplitFetcher and manage the life cycles of them.

Classes in org.apache.flink.connector.base.source.reader.fetcher used by org.apache.flink.connector.pulsar.source.reader.fetcher

Class and Description
SplitFetcher The internal fetcher runnable responsible for polling message from the external system.
SplitFetcherManager A class responsible for starting the SplitFetcher and manage the life cycles of them.