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

Interface Summary

Interface	Description
SplitFetcherTask	An interface similar to Runnable but allows throwing exceptions and wakeup.

Class Summary

Class	Description
SingleThreadFetcherManager<E,SplitT extends SourceSplit>	A Fetcher Manager with a single fetching thread (I/O thread) that handles all splits concurrently.
SplitFetcher<E,SplitT extends SourceSplit>	The internal fetcher runnable responsible for polling message from the external system.
SplitFetcherManager<E,SplitT extends SourceSplit>	A class responsible for starting the SplitFetcher and manage the life cycles of them.