Package org.apache.flink.streaming.api.operators.async.queue
-
Interface Summary Interface Description StreamElementQueue<OUT> Interface for stream element queues for theAsyncWaitOperator.StreamElementQueueEntry<OUT> An entry for theStreamElementQueue. -
Class Summary Class Description OrderedStreamElementQueue<OUT> OrderedStreamElementQueueimplementation.StreamRecordQueueEntry<OUT> StreamElementQueueEntryimplementation forStreamRecord.UnorderedStreamElementQueue<OUT> Unordered implementation of theStreamElementQueue.