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 -
Classes in org.apache.flink.connector.base.source.reader.fetcher used by org.apache.flink.connector.base.source.reader Class Description SingleThreadFetcherManager A Fetcher Manager with a single fetching thread (I/O thread) that handles all splits concurrently.SplitFetcherManager A class responsible for starting theSplitFetcherand 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 Description SplitFetcher The internal fetcher runnable responsible for polling message from the external system.SplitFetcherManager A class responsible for starting theSplitFetcherand manage the life cycles of them.SplitFetcherTask An interface similar toRunnablebut allows throwing exceptions and wakeup.