AbstractExecutionGraphHandler(CompletableFuture<String> localRestAddress,
GatewayRetriever<? extends RestfulGateway> leaderRetriever,
Time timeout,
MessageHeaders<EmptyRequestBody,R,M> messageHeaders,
ExecutionGraphCache executionGraphCache,
Executor executor) |
BlobServerPortHandler(CompletableFuture<String> localRestAddress,
GatewayRetriever<DispatcherGateway> leaderRetriever,
Time timeout) |
JobConfigHandler(CompletableFuture<String> localRestAddress,
GatewayRetriever<? extends RestfulGateway> leaderRetriever,
Time timeout,
MessageHeaders<EmptyRequestBody,JobConfigInfo,JobMessageParameters> messageHeaders,
ExecutionGraphCache executionGraphCache,
Executor executor) |
JobExceptionsHandler(CompletableFuture<String> localRestAddress,
GatewayRetriever<? extends RestfulGateway> leaderRetriever,
Time timeout,
MessageHeaders<EmptyRequestBody,JobExceptionsInfo,JobMessageParameters> messageHeaders,
ExecutionGraphCache executionGraphCache,
Executor executor) |
JobPlanHandler(CompletableFuture<String> localRestAddress,
GatewayRetriever<? extends RestfulGateway> leaderRetriever,
Time timeout,
MessageHeaders<EmptyRequestBody,JobPlanInfo,JobMessageParameters> messageHeaders,
ExecutionGraphCache executionGraphCache,
Executor executor) |
JobSubmitHandler(CompletableFuture<String> localRestAddress,
GatewayRetriever<DispatcherGateway> leaderRetriever,
Time timeout) |
JobTerminationHandler(CompletableFuture<String> localRestAddress,
GatewayRetriever<DispatcherGateway> leaderRetriever,
Time timeout,
MessageHeaders<EmptyRequestBody,EmptyResponseBody,JobTerminationMessageParameters> messageHeaders) |
JobVertexAccumulatorsHandler(CompletableFuture<String> localRestAddress,
GatewayRetriever<? extends RestfulGateway> leaderRetriever,
Time timeout,
MessageHeaders<EmptyRequestBody,JobVertexAccumulatorsInfo,JobVertexMessageParameters> messageHeaders,
ExecutionGraphCache executionGraphCache,
Executor executor) |