Package | Description |
---|---|
org.apache.flink.runtime.webmonitor | |
org.apache.flink.runtime.webmonitor.handlers |
Constructor and Description |
---|
RuntimeMonitorHandler(RequestHandler handler,
JobManagerRetriever retriever,
scala.concurrent.Future<String> localJobManagerAddressFuture,
scala.concurrent.duration.FiniteDuration timeout) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractExecutionGraphRequestHandler
Base class for request handlers whose response depends on an ExecutionGraph
that can be retrieved via "jobid" parameter.
|
class |
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).
|
class |
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).
|
class |
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).
|
class |
ClusterOverviewHandler
Responder that returns the status of the Flink cluster, such as how many
TaskManagers are currently connected, and how many jobs are running.
|
class |
CurrentJobIdsHandler
Responder that returns with a list of all JobIDs of jobs found at the target actor.
|
class |
CurrentJobsOverviewHandler
Request handler that returns a summary of the job status.
|
class |
DashboardConfigHandler
Responder that returns the parameters that define how the asynchronous requests
against this web server should behave.
|
class |
JarAccessDeniedHandler |
class |
JarActionHandler
Abstract handler for fetching plan for a jar or running a jar.
|
class |
JarDeleteHandler
Handles requests for deletion of jars.
|
class |
JarListHandler |
class |
JarPlanHandler
This handler handles requests to fetch plan for a jar.
|
class |
JarRunHandler
This handler handles requests to fetch plan for a jar.
|
class |
JarUploadHandler
Handles requests for uploading of jars.
|
class |
JobAccumulatorsHandler
Request handler that returns the aggregated user accumulators of a job.
|
class |
JobCancellationHandler
Request handler for the CANCEL request.
|
class |
JobCheckpointsHandler
Request handler that returns checkpoint stats for a job.
|
class |
JobConfigHandler
Request handler that returns the execution config of a job.
|
class |
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
|
class |
JobExceptionsHandler
Request handler that returns the configuration of a job.
|
class |
JobManagerConfigHandler
Returns the Job Manager's configuration.
|
class |
JobPlanHandler
Request handler that returns the JSON program plan of a job graph.
|
class |
JobStoppingHandler
Request handler for the STOP request.
|
class |
JobVertexAccumulatorsHandler |
class |
JobVertexBackPressureHandler
Request handler that returns back pressure stats for a single job vertex and
all its sub tasks.
|
class |
JobVertexCheckpointsHandler
Request handler that returns checkpoint stats for a single job vertex.
|
class |
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.
|
class |
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.
|
class |
SubtaskCurrentAttemptDetailsHandler
Request handler providing details about a single task execution attempt.
|
class |
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).
|
class |
SubtaskExecutionAttemptDetailsHandler
Request handler providing details about a single task execution attempt.
|
class |
SubtasksAllAccumulatorsHandler
Request handler that returns the accumulators for all subtasks of job vertex.
|
class |
SubtasksTimesHandler
Request handler that returns the state transition timestamps for all subtasks, plus their
location and duration.
|
class |
TaskManagersHandler |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.