public interface TaskOperatorEventGateway
OperatorEvent
or CoordinationRequest
from a Task to to the
OperatorCoordinator
JobManager side.
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.
OperatorEventGateway
takes the event, enriches the event with the OperatorID
, and
forwards it to:TaskOperatorEventGateway
enriches the event with the ExecutionAttemptID
and
forwards it to the:JobMasterOperatorEventGateway
which is RPC interface from the TaskManager to the JobManager.Modifier and Type | Method and Description |
---|---|
void |
sendOperatorEventToCoordinator(OperatorID operator,
SerializedValue<OperatorEvent> event)
Sends an event from the operator (identified by the given operator ID) to the operator
coordinator (identified by the same ID).
|
CompletableFuture<CoordinationResponse> |
sendRequestToCoordinator(OperatorID operator,
SerializedValue<CoordinationRequest> request)
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–2024 The Apache Software Foundation. All rights reserved.