protected CompletableFuture<MultipleJobsDetails> |
JobsOverviewHandler.handleRequest(HandlerRequest<EmptyRequestBody,EmptyMessageParameters> request,
RestfulGateway gateway) |
protected CompletableFuture<JobIdsWithStatusOverview> |
JobIdsHandler.handleRequest(HandlerRequest<EmptyRequestBody,EmptyMessageParameters> request,
RestfulGateway gateway) |
protected JobAccumulatorsInfo |
JobAccumulatorsHandler.handleRequest(HandlerRequest<EmptyRequestBody,JobAccumulatorsMessageParameters> request,
AccessExecutionGraph graph) |
protected JobPlanInfo |
JobPlanHandler.handleRequest(HandlerRequest<EmptyRequestBody,JobMessageParameters> request,
AccessExecutionGraph executionGraph) |
protected JobDetailsInfo |
JobDetailsHandler.handleRequest(HandlerRequest<EmptyRequestBody,JobMessageParameters> request,
AccessExecutionGraph executionGraph) |
protected CompletableFuture<JobExecutionResultResponseBody> |
JobExecutionResultHandler.handleRequest(HandlerRequest<EmptyRequestBody,JobMessageParameters> request,
RestfulGateway gateway) |
protected JobVertexTaskManagersInfo |
JobVertexTaskManagersHandler.handleRequest(HandlerRequest<EmptyRequestBody,JobVertexMessageParameters> request,
AccessExecutionGraph executionGraph) |
protected JobVertexAccumulatorsInfo |
JobVertexAccumulatorsHandler.handleRequest(HandlerRequest<EmptyRequestBody,JobVertexMessageParameters> request,
AccessExecutionJobVertex jobVertex) |
protected SubtasksAllAccumulatorsInfo |
SubtasksAllAccumulatorsHandler.handleRequest(HandlerRequest<EmptyRequestBody,JobVertexMessageParameters> request,
AccessExecutionJobVertex jobVertex) |
protected CompletableFuture<JobVertexBackPressureInfo> |
JobVertexBackPressureHandler.handleRequest(HandlerRequest<EmptyRequestBody,JobVertexMessageParameters> request,
RestfulGateway gateway) |
protected abstract R |
AbstractSubtaskAttemptHandler.handleRequest(HandlerRequest<EmptyRequestBody,M> request,
AccessExecution execution)
|
protected R |
AbstractJobVertexHandler.handleRequest(HandlerRequest<EmptyRequestBody,M> request,
AccessExecutionGraph executionGraph) |
protected abstract R |
AbstractExecutionGraphHandler.handleRequest(HandlerRequest<EmptyRequestBody,M> request,
AccessExecutionGraph executionGraph)
|
protected abstract R |
AbstractJobVertexHandler.handleRequest(HandlerRequest<EmptyRequestBody,M> request,
AccessExecutionJobVertex jobVertex)
|
protected R |
AbstractSubtaskHandler.handleRequest(HandlerRequest<EmptyRequestBody,M> request,
AccessExecutionJobVertex jobVertex) |
protected R |
AbstractSubtaskAttemptHandler.handleRequest(HandlerRequest<EmptyRequestBody,M> request,
AccessExecutionVertex executionVertex) |
protected abstract R |
AbstractSubtaskHandler.handleRequest(HandlerRequest<EmptyRequestBody,M> request,
AccessExecutionVertex executionVertex)
|
protected CompletableFuture<R> |
AbstractExecutionGraphHandler.handleRequest(HandlerRequest<EmptyRequestBody,M> request,
RestfulGateway gateway) |
protected SubtaskExecutionAttemptAccumulatorsInfo |
SubtaskExecutionAttemptAccumulatorsHandler.handleRequest(HandlerRequest<EmptyRequestBody,SubtaskAttemptMessageParameters> request,
AccessExecution execution) |
protected SubtaskExecutionAttemptDetailsInfo |
SubtaskExecutionAttemptDetailsHandler.handleRequest(HandlerRequest<EmptyRequestBody,SubtaskAttemptMessageParameters> request,
AccessExecution execution) |
protected SubtaskExecutionAttemptDetailsInfo |
SubtaskCurrentAttemptDetailsHandler.handleRequest(HandlerRequest<EmptyRequestBody,SubtaskMessageParameters> request,
AccessExecutionVertex executionVertex) |
protected CompletableFuture<JobSubmitResponseBody> |
JobSubmitHandler.handleRequest(HandlerRequest<JobSubmitRequestBody,EmptyMessageParameters> request,
DispatcherGateway gateway) |