org.apache.flink.runtime.scheduler

Interface OperatorCoordinatorHandler

All Known Implementing Classes:

DefaultOperatorCoordinatorHandler

public interface OperatorCoordinatorHandler

Handler for the OperatorCoordinators.

Method Summary

Modifier and Type	Method and Description
CompletableFuture<CoordinationResponse>	deliverCoordinationRequestToCoordinator(OperatorID operator, CoordinationRequest request) Deliver coordination request from the client to the coordinator.
void	deliverOperatorEventToCoordinator(ExecutionAttemptID taskExecutionId, OperatorID operatorId, OperatorEvent event) Delivers an OperatorEvent to a OperatorCoordinator.
void	disposeAllOperatorCoordinators() Dispose all operator coordinators.
void	initializeOperatorCoordinators(ComponentMainThreadExecutor mainThreadExecutor) Initialize operator coordinators.
void	registerAndStartNewCoordinators(Collection<OperatorCoordinatorHolder> coordinators, ComponentMainThreadExecutor mainThreadExecutor, int parallelism) Register and start new operator coordinators.
void	startAllOperatorCoordinators() Start all operator coordinators.

Method Detail

initializeOperatorCoordinators

void initializeOperatorCoordinators(ComponentMainThreadExecutor mainThreadExecutor)

Initialize operator coordinators.

Parameters:

mainThreadExecutor - Executor for submitting work to the main thread.

startAllOperatorCoordinators

void startAllOperatorCoordinators()

Start all operator coordinators.

disposeAllOperatorCoordinators

void disposeAllOperatorCoordinators()

Dispose all operator coordinators.

deliverOperatorEventToCoordinator

void deliverOperatorEventToCoordinator(ExecutionAttemptID taskExecutionId,
                                       OperatorID operatorId,
                                       OperatorEvent event)
                                throws FlinkException

Delivers an OperatorEvent to a OperatorCoordinator.

Parameters:

taskExecutionId - Execution attempt id of the originating task.

operatorId - OperatorId of the target OperatorCoordinator.

event - Event to deliver to the OperatorCoordinator.

Throws:

FlinkException - If no coordinator is registered for operator.

deliverCoordinationRequestToCoordinator

CompletableFuture<CoordinationResponse> deliverCoordinationRequestToCoordinator(OperatorID operator,
                                                                                CoordinationRequest request)
                                                                         throws FlinkException

Deliver coordination request from the client to the coordinator.

Parameters:

operator - Id of target operator.

request - request for the operator.

Returns:

Future with the response.

Throws:

FlinkException - If the coordinator doesn't exist or if it can not handle the request.

registerAndStartNewCoordinators

void registerAndStartNewCoordinators(Collection<OperatorCoordinatorHolder> coordinators,
                                     ComponentMainThreadExecutor mainThreadExecutor,
                                     int parallelism)

Register and start new operator coordinators.

Parameters:

coordinators - the operator coordinator to be registered.

mainThreadExecutor - Executor for submitting work to the main thread.