public class RpcTaskOperatorEventGateway extends Object implements TaskOperatorEventGateway
JobMasterOperatorEventGateway
to send
the messages to the coordinator.Constructor and Description |
---|
RpcTaskOperatorEventGateway(JobMasterOperatorEventGateway rpcGateway,
ExecutionAttemptID taskExecutionId,
java.util.function.Consumer<Throwable> errorHandler) |
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.
|
public RpcTaskOperatorEventGateway(JobMasterOperatorEventGateway rpcGateway, ExecutionAttemptID taskExecutionId, java.util.function.Consumer<Throwable> errorHandler)
public void sendOperatorEventToCoordinator(OperatorID operator, SerializedValue<OperatorEvent> event)
TaskOperatorEventGateway
sendOperatorEventToCoordinator
in interface TaskOperatorEventGateway
public CompletableFuture<CoordinationResponse> sendRequestToCoordinator(OperatorID operator, SerializedValue<CoordinationRequest> request)
TaskOperatorEventGateway
sendRequestToCoordinator
in interface TaskOperatorEventGateway
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.