@Internal public final class OperatorEventDispatcherImpl extends Object implements OperatorEventDispatcher
OperatorEventDispatcher
.
This class is intended for single threaded use from the stream task mailbox.
Constructor and Description |
---|
OperatorEventDispatcherImpl(ClassLoader classLoader,
TaskOperatorEventGateway toCoordinator) |
Modifier and Type | Method and Description |
---|---|
OperatorEventGateway |
getOperatorEventGateway(OperatorID operatorId)
Gets the gateway through which events can be passed to the OperatorCoordinator for the
operator identified by the given OperatorID.
|
void |
registerEventHandler(OperatorID operator,
OperatorEventHandler handler)
Register a listener that is notified every time an OperatorEvent is sent from the
OperatorCoordinator (of the operator with the given OperatorID) to this subtask.
|
public OperatorEventDispatcherImpl(ClassLoader classLoader, TaskOperatorEventGateway toCoordinator)
public void registerEventHandler(OperatorID operator, OperatorEventHandler handler)
OperatorEventDispatcher
registerEventHandler
in interface OperatorEventDispatcher
public OperatorEventGateway getOperatorEventGateway(OperatorID operatorId)
OperatorEventDispatcher
getOperatorEventGateway
in interface OperatorEventDispatcher
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.