Uses of Interface
org.apache.flink.streaming.api.operators.async.OperatorActions

Packages that use OperatorActions

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

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

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

Modifier and Type	Class and Description
class	AsyncWaitOperator<IN,OUT> The AsyncWaitOperator allows to asynchronously process incoming stream records.

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

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

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

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

Constructor and Description
OrderedStreamElementQueue(int capacity, Executor executor, OperatorActions operatorActions)
UnorderedStreamElementQueue(int capacity, Executor executor, OperatorActions operatorActions)