public interface TaskExecutorOperatorEventGateway
OperatorCoordinatorcan send an event to an Operator on the Task Manager side.
|Modifier and Type||Method and Description|
Sends an operator event to an operator in a task executed by the Task Manager (Task Executor).
CompletableFuture<Acknowledge> sendOperatorEventToTask(ExecutionAttemptID task, OperatorID operator, SerializedValue<OperatorEvent> evt)
The reception is acknowledged (future is completed) when the event has been dispatched to
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
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.