Deprecated API

Contents

• Constructors

Constructors

Constructor	Description
org.apache.flink.connector.base.sink.writer.AsyncSinkWriter(ElementConverter<InputT, RequestEntryT>, Sink.InitContext, int, int, int, long, long, long)
org.apache.flink.connector.base.source.reader.fetcher.SingleThreadFetcherManager(FutureCompletingBlockingQueue<RecordsWithSplitIds<E>>, Supplier<SplitReader<E, SplitT>>)	Please use SingleThreadFetcherManager(Supplier, Configuration) instead.
org.apache.flink.connector.base.source.reader.fetcher.SplitFetcherManager(FutureCompletingBlockingQueue<RecordsWithSplitIds<E>>, Supplier<SplitReader<E, SplitT>>, Configuration)	Please use SplitFetcherManager(Supplier, Configuration) instead.
org.apache.flink.connector.base.source.reader.SingleThreadMultiplexSourceReaderBase(FutureCompletingBlockingQueue<RecordsWithSplitIds<E>>, Supplier<SplitReader<E, SplitT>>, RecordEmitter<E, T, SplitStateT>, Configuration, SourceReaderContext)	Please use SingleThreadMultiplexSourceReaderBase(Supplier, RecordEmitter, Configuration, SourceReaderContext) instead.
org.apache.flink.connector.base.source.reader.SourceReaderBase(FutureCompletingBlockingQueue<RecordsWithSplitIds<E>>, SplitFetcherManager<E, SplitT>, RecordEmitter<E, T, SplitStateT>, Configuration, SourceReaderContext)	Please use SourceReaderBase(SplitFetcherManager, RecordEmitter, Configuration, SourceReaderContext) instead.