JobVertexAccumulatorsHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever,
Time timeout,
Map<String,String> responseHeaders,
MessageHeaders<EmptyRequestBody,JobVertexAccumulatorsInfo,JobVertexMessageParameters> messageHeaders,
ExecutionGraphCache executionGraphCache,
Executor executor) |
JobVertexBackPressureHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever,
Time timeout,
Map<String,String> responseHeaders,
MessageHeaders<EmptyRequestBody,JobVertexBackPressureInfo,JobVertexMessageParameters> messageHeaders,
MetricFetcher metricFetcher) |
JobVertexDetailsHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever,
Time timeout,
Map<String,String> responseHeaders,
MessageHeaders<EmptyRequestBody,JobVertexDetailsInfo,JobVertexMessageParameters> messageHeaders,
ExecutionGraphCache executionGraphCache,
Executor executor,
MetricFetcher metricFetcher) |
JobVertexTaskManagersHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever,
Time timeout,
Map<String,String> responseHeaders,
MessageHeaders<EmptyRequestBody,JobVertexTaskManagersInfo,JobVertexMessageParameters> messageHeaders,
ExecutionGraphCache executionGraphCache,
Executor executor,
MetricFetcher metricFetcher) |
SubtasksAllAccumulatorsHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever,
Time timeout,
Map<String,String> responseHeaders,
MessageHeaders<EmptyRequestBody,SubtasksAllAccumulatorsInfo,JobVertexMessageParameters> messageHeaders,
ExecutionGraphCache executionGraphCache,
Executor executor) |
SubtasksTimesHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever,
Time timeout,
Map<String,String> responseHeaders,
MessageHeaders<EmptyRequestBody,SubtasksTimesInfo,JobVertexMessageParameters> messageHeaders,
ExecutionGraphCache executionGraphCache,
Executor executor) |