Interface | Description |
---|---|
RequestHandler |
Base interface for all request handlers.
|
Class | Description |
---|---|
AbstractExecutionGraphRequestHandler |
Base class for request handlers whose response depends on an ExecutionGraph
that can be retrieved via "jobid" parameter.
|
AbstractJobVertexRequestHandler |
Base class for request handlers whose response depends on a specific job vertex (defined
via the "vertexid" parameter) in a specific job, defined via (defined voa the "jobid" parameter).
|
AbstractJsonRequestHandler |
Base class for most request handlers.
|
AbstractSubtaskAttemptRequestHandler |
Base class for request handlers whose response depends on a specific subtask execution attempt
(defined via the "attempt" parameter) of a specific subtask (defined via the
"subtasknum" parameter) in a specific job vertex (defined via the "vertexid" parameter) in a
specific job, defined via (defined voa the "jobid" parameter).
|
AbstractSubtaskRequestHandler |
Base class for request handlers whose response depends on a specific subtask (defined via the
"subtasknum" parameter) in a specific job vertex (defined via the "vertexid" parameter) in a
specific job, defined via (defined voa the "jobid" parameter).
|
ClusterConfigHandler |
Returns the Job Manager's configuration.
|
ClusterOverviewHandler |
Responder that returns the status of the Flink cluster, such as how many
TaskManagers are currently connected, and how many jobs are running.
|
ConstantTextHandler |
Responder that returns a constant String.
|
CurrentJobIdsHandler |
Responder that returns with a list of all JobIDs of jobs found at the target actor.
|
CurrentJobsOverviewHandler |
Request handler that returns a summary of the job status.
|
CurrentJobsOverviewHandler.CurrentJobsOverviewJsonArchivist |
Archivist for the CurrentJobsOverviewHandler.
|
DashboardConfigHandler |
Responder that returns the parameters that define how the asynchronous requests
against this web server should behave.
|
ExecutionGraphCache |
Cache for
AccessExecutionGraph which are obtained from the Flink cluster. |
JobAccumulatorsHandler |
Request handler that returns the aggregated user accumulators of a job.
|
JobAccumulatorsHandler.JobAccumulatorsJsonArchivist |
Archivist for the JobAccumulatorsHandler.
|
JobCancellationHandler |
Request handler for the cancel request.
|
JobCancellationWithSavepointHandlers |
Request handler for
JobManagerMessages.CancelJobWithSavepoint messages. |
JobConfigHandler |
Request handler that returns the execution config of a job.
|
JobConfigHandler.JobConfigJsonArchivist |
Archivist for the JobConfigHandler.
|
JobDetailsHandler |
Request handler that returns details about a job.
|
JobDetailsHandler.JobDetailsJsonArchivist |
Archivist for the JobDetailsHandler.
|
JobExceptionsHandler |
Request handler that returns the configuration of a job.
|
JobExceptionsHandler.JobExceptionsJsonArchivist |
Archivist for the JobExceptionsHandler.
|
JobPlanHandler |
Request handler that returns the JSON program plan of a job graph.
|
JobPlanHandler.JobPlanJsonArchivist |
Archivist for the JobPlanHandler.
|
JobStoppingHandler |
Request handler for the STOP request.
|
JobVertexAccumulatorsHandler |
Request handler that returns the accummulators for a given vertex.
|
JobVertexAccumulatorsHandler.JobVertexAccumulatorsJsonArchivist |
Archivist for JobVertexAccumulatorsHandler.
|
JobVertexBackPressureHandler |
Request handler that returns back pressure stats for a single job vertex and
all its sub tasks.
|
JobVertexDetailsHandler |
A request handler that provides the details of a job vertex, including id, name, parallelism,
and the runtime and metrics of all its subtasks.
|
JobVertexDetailsHandler.JobVertexDetailsJsonArchivist |
Archivist for the JobVertexDetailsHandler.
|
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.
|
JobVertexTaskManagersHandler.JobVertexTaskManagersJsonArchivist |
Archivist for JobVertexTaskManagersHandler.
|
JsonFactory |
A holder for the singleton Jackson JSON factory.
|
SubtaskCurrentAttemptDetailsHandler |
Request handler providing details about a single task execution attempt.
|
SubtaskExecutionAttemptAccumulatorsHandler |
Base class for request handlers whose response depends on a specific job vertex (defined
via the "vertexid" parameter) in a specific job, defined via (defined voa the "jobid" parameter).
|
SubtaskExecutionAttemptAccumulatorsHandler.SubtaskExecutionAttemptAccumulatorsJsonArchivist |
Archivist for the SubtaskExecutionAttemptAccumulatorsHandler.
|
SubtaskExecutionAttemptDetailsHandler |
Request handler providing details about a single task execution attempt.
|
SubtaskExecutionAttemptDetailsHandler.SubtaskExecutionAttemptDetailsJsonArchivist |
Archivist for the SubtaskExecutionAttemptDetailsHandler.
|
SubtasksAllAccumulatorsHandler |
Request handler that returns the accumulators for all subtasks of job vertex.
|
SubtasksAllAccumulatorsHandler.SubtasksAllAccumulatorsJsonArchivist |
Archivist for the SubtasksAllAccumulatorsHandler.
|
SubtasksTimesHandler |
Request handler that returns the state transition timestamps for all subtasks, plus their
location and duration.
|
SubtasksTimesHandler.SubtasksTimesJsonArchivist |
Archivist for the SubtasksTimesHandler.
|
TaskManagerLogHandler |
Request handler that returns the TaskManager log/out files.
|
TaskManagersHandler |
A request handler that provides an overview over all taskmanagers or details for a single one.
|
Enum | Description |
---|---|
TaskManagerLogHandler.FileMode |
Used to control whether this handler serves the .log or .out file.
|
Exception | Description |
---|---|
RequestHandlerException |
Base class for request handler exceptions.
|
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.