Modifier and Type | Class and Description |
---|---|
class |
AbstractAccessExecutionGraphHandler<R extends ResponseBody,M extends JobMessageParameters>
AbstractAccessExecutionGraphHandler handles requests that require accessing the job's
AccessExecutionGraph . |
class |
AbstractExecutionGraphHandler<R extends ResponseBody,M extends JobMessageParameters>
Base class for all
ExecutionGraphInfo based REST handlers. |
Modifier and Type | Class and Description |
---|---|
class |
AbstractCheckpointStatsHandler<R extends ResponseBody,M extends JobMessageParameters>
Abstract class for checkpoint handlers that will cache the
CheckpointStatsSnapshot
object. |
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,
org.apache.flink.shaded.guava31.com.google.common.cache.Cache<JobID,CompletableFuture<CheckpointStatsSnapshot>> checkpointStatsSnapshotCache,
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 |
JobTaskManagerMessageParameters
Message parameters which require a job path parameter and a TaskManager id path parameter.
|
class |
JobVertexFlameGraphParameters
Message parameters for job vertex Flame Graph REST handler.
|
class |
JobVertexMessageParameters
Message parameters for job vertex REST handlers.
|
Modifier and Type | Method and Description |
---|---|
JobMessageParameters |
JobManagerLogUrlHeaders.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() |
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 |
JobManagerJobConfigurationHeaders.getUnresolvedMessageParameters() |
JobMessageParameters |
JobExecutionResultHeaders.getUnresolvedMessageParameters() |
JobMessageParameters |
JobStatusInfoHeaders.getUnresolvedMessageParameters() |
JobMessageParameters |
JobResourcesRequirementsUpdateHeaders.getUnresolvedMessageParameters() |
JobMessageParameters |
JobDetailsHeaders.getUnresolvedMessageParameters() |
JobMessageParameters |
JobManagerJobEnvironmentHeaders.getUnresolvedMessageParameters() |
JobMessageParameters |
JobResourceRequirementsHeaders.getUnresolvedMessageParameters() |
Modifier and Type | Class and Description |
---|---|
class |
JobMetricsMessageParameters
|
class |
JobVertexMetricsMessageParameters
|
class |
SubtaskMetricsMessageParameters
|
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.