Modifier and Type | Class and Description |
---|---|
class |
AbstractExecutionGraphHandler<R extends ResponseBody,M extends JobMessageParameters>
Base class for all
AccessExecutionGraph based REST handlers. |
Modifier and Type | Method and Description |
---|---|
protected JobConfigInfo |
JobConfigHandler.handleRequest(HandlerRequest<EmptyRequestBody,JobMessageParameters> request,
AccessExecutionGraph executionGraph) |
protected JobPlanInfo |
JobPlanHandler.handleRequest(HandlerRequest<EmptyRequestBody,JobMessageParameters> request,
AccessExecutionGraph executionGraph) |
protected JobExceptionsInfo |
JobExceptionsHandler.handleRequest(HandlerRequest<EmptyRequestBody,JobMessageParameters> request,
AccessExecutionGraph executionGraph) |
Constructor and Description |
---|
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) |
Modifier and Type | Method and Description |
---|---|
protected CheckpointConfigInfo |
CheckpointConfigHandler.handleRequest(HandlerRequest<EmptyRequestBody,JobMessageParameters> request,
AccessExecutionGraph executionGraph) |
protected CheckpointingStatistics |
CheckpointingStatisticsHandler.handleRequest(HandlerRequest<EmptyRequestBody,JobMessageParameters> request,
AccessExecutionGraph executionGraph) |
Constructor and Description |
---|
CheckpointConfigHandler(CompletableFuture<String> localRestAddress,
GatewayRetriever<? extends RestfulGateway> leaderRetriever,
Time timeout,
MessageHeaders<EmptyRequestBody,CheckpointConfigInfo,JobMessageParameters> messageHeaders,
ExecutionGraphCache executionGraphCache,
Executor executor) |
CheckpointingStatisticsHandler(CompletableFuture<String> localRestAddress,
GatewayRetriever<? extends RestfulGateway> leaderRetriever,
Time timeout,
MessageHeaders<EmptyRequestBody,CheckpointingStatistics,JobMessageParameters> messageHeaders,
ExecutionGraphCache executionGraphCache,
Executor executor) |
Modifier and Type | Class and Description |
---|---|
class |
JobVertexMessageParameters
Message parameters for job vertex REST handlers.
|
Modifier and Type | Method and Description |
---|---|
JobMessageParameters |
JobExceptionsHeaders.getUnresolvedMessageParameters() |
JobMessageParameters |
JobPlanHeaders.getUnresolvedMessageParameters() |
JobMessageParameters |
JobConfigHeaders.getUnresolvedMessageParameters() |
Modifier and Type | Class and Description |
---|---|
class |
CheckpointMessageParameters
Message parameters for checkpoint related messages.
|
class |
TaskCheckpointMessageParameters
Message parameters for subtask related checkpoint message.
|
Modifier and Type | Method and Description |
---|---|
JobMessageParameters |
CheckpointConfigHeaders.getUnresolvedMessageParameters() |
JobMessageParameters |
CheckpointingStatisticsHeaders.getUnresolvedMessageParameters() |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.