Uses of Class org.apache.flink.connector.base.source.reader.fetcher.SingleThreadFetcherManager (Flink : Connectors : Base 2.2.0-cp1 API)

Packages that use SingleThreadFetcherManager
Package Description

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

Uses of SingleThreadFetcherManager in org.apache.flink.connector.base.source.reader

Constructors in org.apache.flink.connector.base.source.reader with parameters of type SingleThreadFetcherManager
Constructor	Description
`SingleThreadMultiplexSourceReaderBase(SingleThreadFetcherManager<E,SplitT> splitFetcherManager, RecordEmitter<E,T,SplitStateT> recordEmitter, org.apache.flink.configuration.Configuration config, org.apache.flink.api.connector.source.SourceReaderContext context)`	This constructor behaves like `SingleThreadMultiplexSourceReaderBase(Supplier, RecordEmitter, Configuration, SourceReaderContext)`, but accepts a specific `SingleThreadFetcherManager`.
`SingleThreadMultiplexSourceReaderBase(SingleThreadFetcherManager<E,SplitT> splitFetcherManager, RecordEmitter<E,T,SplitStateT> recordEmitter, RecordEvaluator<T> eofRecordEvaluator, org.apache.flink.configuration.Configuration config, org.apache.flink.api.connector.source.SourceReaderContext context)`	This constructor behaves like `SingleThreadMultiplexSourceReaderBase(Supplier, RecordEmitter, Configuration, SourceReaderContext)`, but accepts a specific `SingleThreadFetcherManager` and `RecordEvaluator`.
`SingleThreadMultiplexSourceReaderBase(SingleThreadFetcherManager<E,SplitT> splitFetcherManager, RecordEmitter<E,T,SplitStateT> recordEmitter, RecordEvaluator<T> eofRecordEvaluator, org.apache.flink.configuration.Configuration config, org.apache.flink.api.connector.source.SourceReaderContext context, org.apache.flink.api.connector.source.util.ratelimit.RateLimiterStrategy<SplitT> rateLimiterStrategy)`	This constructor behaves like `SingleThreadMultiplexSourceReaderBase(SingleThreadFetcherManager, RecordEmitter, RecordEvaluator, Configuration, SourceReaderContext)`, but accepts a specific `RateLimiterStrategy`.