Uses of Package
org.apache.flink.connector.base.source.reader.synchronization

Packages that use org.apache.flink.connector.base.source.reader.synchronization

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.synchronization used by org.apache.flink.connector.base.source.reader

Class	Description
FutureCompletingBlockingQueue	A custom implementation of blocking queue in combination with a CompletableFuture that is used in the hand-over of data from a producing thread to a consuming thread.

Classes in org.apache.flink.connector.base.source.reader.synchronization used by org.apache.flink.connector.base.source.reader.fetcher

Class	Description
FutureCompletingBlockingQueue	A custom implementation of blocking queue in combination with a CompletableFuture that is used in the hand-over of data from a producing thread to a consuming thread.