org.apache.flink.runtime.taskexecutor

Interface TaskExecutorOperatorEventGateway

All Known Subinterfaces:

TaskExecutorGateway, TaskManagerGateway

All Known Implementing Classes:

RpcTaskManagerGateway, TaskExecutor, TaskExecutorGatewayDecoratorBase

public interface TaskExecutorOperatorEventGateway

The gateway through which the OperatorCoordinator can send an event to an Operator on the Task Manager side.

Method Summary

Modifier and Type	Method and Description
CompletableFuture<Acknowledge>	sendOperatorEventToTask(ExecutionAttemptID task, OperatorID operator, SerializedValue<OperatorEvent> evt) Sends an operator event to an operator in a task executed by the Task Manager (Task Executor).

Method Detail

sendOperatorEventToTask

CompletableFuture<Acknowledge> sendOperatorEventToTask(ExecutionAttemptID task,
                                                       OperatorID operator,
                                                       SerializedValue<OperatorEvent> evt)

Sends an operator event to an operator in a task executed by the Task Manager (Task Executor).

The reception is acknowledged (future is completed) when the event has been dispatched to the AbstractInvokable.dispatchOperatorEvent(OperatorID, SerializedValue) method. It is not guaranteed that the event is processed successfully within the implementation. These cases are up to the task and event sender to handle (for example with an explicit response message upon success, or by triggering failure/recovery upon exception).