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, java.util.function.Consumer<Throwable> errorHandler)

Method Summary

Modifier and Type	Method and Description
void	sendOperatorEventToCoordinator(OperatorID operator, SerializedValue<OperatorEvent> event) Send an event from the operator (identified by the given operator ID) to the operator coordinator (identified by the same ID).

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,
                                   java.util.function.Consumer<Throwable> errorHandler)

Method Detail

sendOperatorEventToCoordinator

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

Description copied from interface: TaskOperatorEventGateway

Send 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