org.apache.flink.runtime.taskexecutor.rpc

Class RpcTaskOperatorEventGateway

java.lang.Object

org.apache.flink.runtime.taskexecutor.rpc.RpcTaskOperatorEventGateway

All Implemented Interfaces:

TaskOperatorEventGateway

public class RpcTaskOperatorEventGateway
extends Object
implements TaskOperatorEventGateway

An OperatorEventSender that calls the RPC gateway JobMasterOperatorEventGateway to send the messages to the coordinator.

Constructor Summary

Constructors

Constructor and Description
RpcTaskOperatorEventGateway(JobMasterOperatorEventGateway rpcGateway, ExecutionAttemptID taskExecutionId, Consumer<Throwable> errorHandler)

Method Summary

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.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RpcTaskOperatorEventGateway

public RpcTaskOperatorEventGateway(JobMasterOperatorEventGateway rpcGateway,
                                   ExecutionAttemptID taskExecutionId,
                                   Consumer<Throwable> errorHandler)

Method Detail

sendOperatorEventToCoordinator

public void sendOperatorEventToCoordinator(OperatorID operator,
                                           SerializedValue<OperatorEvent> event)

Description copied from interface: TaskOperatorEventGateway

Sends an event from the operator (identified by the given operator ID) to the operator coordinator (identified by the same ID).

Specified by:

sendOperatorEventToCoordinator in interface TaskOperatorEventGateway

sendRequestToCoordinator

public CompletableFuture<CoordinationResponse> sendRequestToCoordinator(OperatorID operator,
                                                                        SerializedValue<CoordinationRequest> request)

Description copied from interface: TaskOperatorEventGateway

Sends a request from current operator to a specified operator coordinator which is identified by the given operator ID and return the response.

Specified by:

sendRequestToCoordinator in interface TaskOperatorEventGateway