Uses of Interface
org.apache.flink.runtime.operators.coordination.OperatorEventDispatcher

Packages that use OperatorEventDispatcher

Package	Description
org.apache.flink.streaming.api.operators
org.apache.flink.streaming.runtime.tasks	This package contains classes that realize streaming tasks.

Uses of OperatorEventDispatcher in org.apache.flink.streaming.api.operators

Methods in org.apache.flink.streaming.api.operators that return OperatorEventDispatcher

Modifier and Type	Method and Description
OperatorEventDispatcher	StreamOperatorParameters.getOperatorEventDispatcher()

Methods in org.apache.flink.streaming.api.operators with parameters of type OperatorEventDispatcher

Modifier and Type	Method and Description
static <OUT,OP extends StreamOperator<OUT>> Tuple2<OP,Optional<ProcessingTimeService>>	StreamOperatorFactoryUtil.createOperator(StreamOperatorFactory<OUT> operatorFactory, StreamTask<OUT,?> containingTask, StreamConfig configuration, Output<StreamRecord<OUT>> output, OperatorEventDispatcher operatorEventDispatcher) Creates a new operator using a factory and makes sure that all special factory traits are properly handled.

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

Constructor and Description
StreamOperatorParameters(StreamTask<?,?> containingTask, StreamConfig config, Output<StreamRecord<OUT>> output, Supplier<ProcessingTimeService> processingTimeServiceFactory, OperatorEventDispatcher operatorEventDispatcher, MailboxExecutor mailboxExecutor)

Uses of OperatorEventDispatcher in org.apache.flink.streaming.runtime.tasks

Classes in org.apache.flink.streaming.runtime.tasks that implement OperatorEventDispatcher

Modifier and Type	Class and Description
class	OperatorEventDispatcherImpl An implementation of the OperatorEventDispatcher.

Methods in org.apache.flink.streaming.runtime.tasks that return OperatorEventDispatcher

Modifier and Type	Method and Description
OperatorEventDispatcher	OperatorChain.getOperatorEventDispatcher()