Package org.apache.flink.streaming.api.operators.async.queue

Interface Summary

Interface	Description
AsyncCollectionResult<T>	AsyncResult sub class for asynchronous result collections.
AsyncResult	Asynchronous result returned by the StreamElementQueue.
AsyncWatermarkResult	AsyncResult subclass for asynchronous result Watermark.
StreamElementQueue	Interface for blocking stream element queues for the AsyncWaitOperator.

Class Summary

Class	Description
OrderedStreamElementQueue	Ordered StreamElementQueue implementation.
StreamElementQueueEntry<T>	Entry class for the StreamElementQueue.
StreamRecordQueueEntry<OUT>	StreamElementQueueEntry implementation for StreamRecord.
UnorderedStreamElementQueue	Unordered implementation of the StreamElementQueue.
WatermarkQueueEntry	StreamElementQueueEntry implementation for the Watermark.