TaskExecutorOperatorEventGateway (Flink : 2.0-preview1 API)

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

All Methods Instance Methods Abstract Methods
Modifier and Type	Method	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).