Class | Description |
---|---|
AbstractAccessExecutionGraphHandler<R extends ResponseBody,M extends JobMessageParameters> |
AbstractAccessExecutionGraphHandler handles requests that require accessing the job's
AccessExecutionGraph . |
AbstractExecutionGraphHandler<R extends ResponseBody,M extends JobMessageParameters> |
Base class for all
ExecutionGraphInfo based REST handlers. |
AbstractJobVertexHandler<R extends ResponseBody,M extends JobVertexMessageParameters> |
Base class for request handlers whose response depends on a specific job vertex (defined via the
"
JobVertexIdPathParameter.KEY " parameter) in a specific job, defined via (defined via the
"JobIDPathParameter.KEY " parameter). |
AbstractSubtaskAttemptHandler<R extends ResponseBody,M extends SubtaskAttemptMessageParameters> |
Base class for request handlers whose response depends on a specific attempt (defined via the
"
SubtaskAttemptPathParameter.KEY " of a specific subtask (defined via the "SubtaskIndexPathParameter.KEY " in a specific job vertex, (defined via the "JobVertexIdPathParameter.KEY " parameter) in a specific job, defined via (defined via the "JobIDPathParameter.KEY " parameter). |
AbstractSubtaskHandler<R extends ResponseBody,M extends SubtaskMessageParameters> |
Base class for request handlers whose response depends on a specific subtask (defined via the
"
SubtaskIndexPathParameter.KEY " in a specific job vertex, (defined via the "JobVertexIdPathParameter.KEY " parameter) in a specific job, defined via (defined via the "JobIDPathParameter.KEY " parameter). |
AsynchronousJobOperationKey | |
GeneratedLogUrlHandler |
Handler for retrieving the log url of a specified TaskManager or JobManager.
|
JobAccumulatorsHandler |
Request handler that returns the aggregated accumulators of a job.
|
JobCancellationHandler |
Request handler for the cancel and stop request.
|
JobClientHeartbeatHandler |
Receive the heartbeat from the client.
|
JobConfigHandler |
Handler serving the job configuration.
|
JobDetailsHandler |
Handler returning the details for the specified job.
|
JobExceptionsHandler |
Handler serving the job exceptions.
|
JobExecutionResultHandler |
Returns the
JobExecutionResult for a given JobID . |
JobIdsHandler |
Handler for job IDs.
|
JobManagerJobConfigurationHandler |
Handler which serves the jobmanager's configuration of a specific job.
|
JobManagerJobEnvironmentHandler |
Handler which serves the jobmanager's environment variables of a specific job.
|
JobPlanHandler |
Handler serving the job execution plan.
|
JobResourceRequirementsHandler |
Rest handler for reading current
resource requirements of a given job. |
JobResourceRequirementsUpdateHandler |
Rest handler for updating
resource requirements of a given job. |
JobsOverviewHandler |
Overview handler for jobs.
|
JobStatusHandler |
Handler for requesting job status.
|
JobSubmitHandler |
This handler can be used to submit jobs to a Flink cluster.
|
JobVertexAccumulatorsHandler |
Request handler for the job vertex accumulators.
|
JobVertexBackPressureHandler |
Request handler for the job vertex back pressure.
|
JobVertexDetailsHandler |
Request handler for the job vertex details.
|
JobVertexFlameGraphHandler |
Request handler for the job vertex Flame Graph.
|
JobVertexTaskManagersHandler |
A request handler that provides the details of a job vertex, including id, name, and the runtime
and metrics of all its subtasks aggregated by TaskManager.
|
SubtaskCurrentAttemptDetailsHandler |
Request handler providing details about a single task execution attempt.
|
SubtaskExecutionAttemptAccumulatorsHandler |
Request handler for the subtask execution attempt accumulators.
|
SubtaskExecutionAttemptDetailsHandler |
Handler of specific sub task execution attempt.
|
SubtasksAllAccumulatorsHandler |
Request handler for the subtasks all accumulators.
|
SubtasksTimesHandler |
Request handler for the subtasks times info.
|
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.