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 JobDetailsInfo |
JobDetailsHandler.handleRequest(HandlerRequest<EmptyRequestBody,JobMessageParameters> request,
AccessExecutionGraph executionGraph) |
protected JobConfigInfo |
JobConfigHandler.handleRequest(HandlerRequest<EmptyRequestBody,JobMessageParameters> request,
AccessExecutionGraph executionGraph) |
protected JobPlanInfo |
JobPlanHandler.handleRequest(HandlerRequest<EmptyRequestBody,JobMessageParameters> request,
AccessExecutionGraph executionGraph) |
protected CompletableFuture<JobExecutionResultResponseBody> |
JobExecutionResultHandler.handleRequest(HandlerRequest<EmptyRequestBody,JobMessageParameters> request,
RestfulGateway gateway) |
Constructor and Description |
---|
JobConfigHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever,
Time timeout,
Map<String,String> responseHeaders,
MessageHeaders<EmptyRequestBody,JobConfigInfo,JobMessageParameters> messageHeaders,
ExecutionGraphCache executionGraphCache,
Executor executor) |
JobDetailsHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever,
Time timeout,
Map<String,String> responseHeaders,
MessageHeaders<EmptyRequestBody,JobDetailsInfo,JobMessageParameters> messageHeaders,
ExecutionGraphCache executionGraphCache,
Executor executor,
MetricFetcher metricFetcher) |
JobPlanHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever,
Time timeout,
Map<String,String> headers,
MessageHeaders<EmptyRequestBody,JobPlanInfo,JobMessageParameters> messageHeaders,
ExecutionGraphCache executionGraphCache,
Executor executor) |
Modifier and Type | Method and Description |
---|---|
protected CheckpointingStatistics |
CheckpointingStatisticsHandler.handleRequest(HandlerRequest<EmptyRequestBody,JobMessageParameters> request,
AccessExecutionGraph executionGraph) |
protected CheckpointConfigInfo |
CheckpointConfigHandler.handleRequest(HandlerRequest<EmptyRequestBody,JobMessageParameters> request,
AccessExecutionGraph executionGraph) |
Constructor and Description |
---|
CheckpointConfigHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever,
Time timeout,
Map<String,String> responseHeaders,
MessageHeaders<EmptyRequestBody,CheckpointConfigInfo,JobMessageParameters> messageHeaders,
ExecutionGraphCache executionGraphCache,
Executor executor) |
CheckpointingStatisticsHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever,
Time timeout,
Map<String,String> responseHeaders,
MessageHeaders<EmptyRequestBody,CheckpointingStatistics,JobMessageParameters> messageHeaders,
ExecutionGraphCache executionGraphCache,
Executor executor) |
Modifier and Type | Class and Description |
---|---|
class |
RescalingStatusMessageParameters
MessageParameters for polling the status of a rescaling operation. |
class |
RescalingTriggerMessageParameters
MessageParameters for triggering the rescaling of a job. |
Modifier and Type | Class and Description |
---|---|
class |
JobAccumulatorsMessageParameters
Request parameter for job accumulator's handler
JobAccumulatorsHandler . |
class |
JobVertexMessageParameters
Message parameters for job vertex REST handlers.
|
Modifier and Type | Method and Description |
---|---|
JobMessageParameters |
JobConfigHeaders.getUnresolvedMessageParameters() |
JobMessageParameters |
JobPlanHeaders.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() |
Modifier and Type | Class and Description |
---|---|
class |
JobExceptionsMessageParameters
|
class |
SubtaskAttemptMessageParameters
The type Subtask attempt message parameters.
|
class |
SubtaskMessageParameters
Message parameters for subtask REST handlers.
|
Modifier and Type | Method and Description |
---|---|
JobMessageParameters |
JobExecutionResultHeaders.getUnresolvedMessageParameters() |
JobMessageParameters |
JobDetailsHeaders.getUnresolvedMessageParameters() |
Modifier and Type | Class and Description |
---|---|
class |
JobMetricsMessageParameters
|
class |
JobVertexMetricsMessageParameters
|
class |
SubtaskMetricsMessageParameters
|
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.