Uses of Class
org.apache.flink.connector.base.source.reader.synchronization.FutureCompletingBlockingQueue

Packages that use FutureCompletingBlockingQueue

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

Uses of FutureCompletingBlockingQueue in org.apache.flink.connector.base.source.reader.fetcher

Methods in org.apache.flink.connector.base.source.reader.fetcher that return FutureCompletingBlockingQueue

Modifier and Type	Method	Description
FutureCompletingBlockingQueue<RecordsWithSplitIds<E>>	SplitFetcherManager.getQueue()	Return the queue contains data produced by split fetchers.This method is Internal and only used in SourceReaderBase.