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

Packages that use StreamElementQueue

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

Uses of StreamElementQueue in org.apache.flink.streaming.api.operators.async

Constructors in org.apache.flink.streaming.api.operators.async with parameters of type StreamElementQueue

Constructor and Description
Emitter(Object checkpointLock, Output<StreamRecord<OUT>> output, StreamElementQueue streamElementQueue, OperatorActions operatorActions)

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

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

Modifier and Type	Class and Description
class	OrderedStreamElementQueue Ordered StreamElementQueue implementation.
class	UnorderedStreamElementQueue Unordered implementation of the StreamElementQueue.