Uses of Interface
org.apache.flink.streaming.api.operators.async.queue.AsyncResult

Packages that use AsyncResult

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

Uses of AsyncResult in org.apache.flink.streaming.api.operators.async.queue

Subinterfaces of AsyncResult in org.apache.flink.streaming.api.operators.async.queue

Modifier and Type	Interface and Description
interface	AsyncCollectionResult<T> AsyncResult sub class for asynchronous result collections.
interface	AsyncWatermarkResult AsyncResult subclass for asynchronous result Watermark.

Classes in org.apache.flink.streaming.api.operators.async.queue that implement AsyncResult

Modifier and Type	Class and Description
class	StreamElementQueueEntry<T> Entry class for the StreamElementQueue.
class	StreamRecordQueueEntry<OUT> StreamElementQueueEntry implementation for StreamRecord.
class	WatermarkQueueEntry StreamElementQueueEntry implementation for the Watermark.

Methods in org.apache.flink.streaming.api.operators.async.queue that return AsyncResult

Modifier and Type	Method and Description
AsyncResult	OrderedStreamElementQueue.peekBlockingly()
AsyncResult	StreamElementQueue.peekBlockingly() Peek at the head of the queue and return the first completed AsyncResult.
AsyncResult	UnorderedStreamElementQueue.peekBlockingly()
AsyncResult	OrderedStreamElementQueue.poll()
AsyncResult	StreamElementQueue.poll() Poll the first completed AsyncResult from the head of this queue.
AsyncResult	UnorderedStreamElementQueue.poll()