public interface TaskOperatorEventGateway
CoordinationRequestfrom a Task to to the
This is the first step in the chain of sending Operator Events and Requests from Operator to Coordinator. Each layer adds further context, so that the inner layers do not need to know about the complete context, which keeps dependencies small and makes testing easier.
OperatorEventGatewaytakes the event, enriches the event with the
OperatorID, and forwards it to:
TaskOperatorEventGatewayenriches the event with the
ExecutionAttemptIDand forwards it to the:
JobMasterOperatorEventGatewaywhich is RPC interface from the TaskManager to the JobManager.
|Modifier and Type||Method and Description|
Sends an event from the operator (identified by the given operator ID) to the operator coordinator (identified by the same ID).
Sends a request from current operator to a specified operator coordinator which is identified by the given operator ID and return the response.
void sendOperatorEventToCoordinator(OperatorID operator, SerializedValue<OperatorEvent> event)
CompletableFuture<CoordinationResponse> sendRequestToCoordinator(OperatorID operator, SerializedValue<CoordinationRequest> request)
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.