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).
|
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).
|
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.
|
DashboardConfigHandler |
Responder that returns the parameters that define how the asynchronous requests
against this web server should behave.
|
HandlerRedirectUtils |
Utilities to extract a redirect address.
|
JarAccessDeniedHandler | |
JarActionHandler |
Abstract handler for fetching plan for a jar or running a jar.
|
JarDeleteHandler |
Handles requests for deletion of jars.
|
JarListHandler | |
JarPlanHandler |
This handler handles requests to fetch plan for a jar.
|
JarRunHandler |
This handler handles requests to fetch plan for a jar.
|
JarUploadHandler |
Handles requests for uploading of jars.
|
JobAccumulatorsHandler |
Request handler that returns the aggregated user accumulators of a job.
|
JobCancellationHandler |
Request handler for the CANCEL request.
|
JobCheckpointsHandler |
Request handler that returns checkpoint stats for a job.
|
JobConfigHandler |
Request handler that returns the execution config of a job.
|
JobDetailsHandler |
Request handler that returns details about a job, including:
Dataflow plan
id, name, and current status
start time, end time, duration
number of job vertices in each state (pending, running, finished, failed)
info about job vertices, including runtime, status, I/O bytes and records, subtasks in each status
|
JobExceptionsHandler |
Request handler that returns the configuration of a job.
|
JobManagerConfigHandler |
Returns the Job Manager's configuration.
|
JobPlanHandler |
Request handler that returns the JSON program plan of a job graph.
|
JobStoppingHandler |
Request handler for the STOP request.
|
JobVertexAccumulatorsHandler | |
JobVertexBackPressureHandler |
Request handler that returns back pressure stats for a single job vertex and
all its sub tasks.
|
JobVertexCheckpointsHandler |
Request handler that returns checkpoint stats for a single job vertex.
|
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.
|
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.
|
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).
|
SubtaskExecutionAttemptDetailsHandler |
Request handler providing details about a single task execution attempt.
|
SubtasksAllAccumulatorsHandler |
Request handler that returns the accumulators for all subtasks of job vertex.
|
SubtasksTimesHandler |
Request handler that returns the state transition timestamps for all subtasks, plus their
location and duration.
|
TaskManagersHandler |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.