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 via the "jobid" parameter).
|
class |
AbstractJsonRequestHandler
Base class for most request handlers.
|
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 |
ClusterConfigHandler
Returns the Job Manager's configuration.
|
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 |
DashboardConfigHandler
Responder that returns the parameters that define how the asynchronous requests
against this web server should behave.
|
class |
JobAccumulatorsHandler
Request handler that returns the aggregated user accumulators of a job.
|
class |
JobCancellationHandler
Request handler for the cancel request.
|
class |
JobConfigHandler
Request handler that returns the execution config of a job.
|
class |
JobDetailsHandler
Request handler that returns details about a job.
|
class |
JobExceptionsHandler
Request handler that returns the configuration of a job.
|
class |
JobPlanHandler
Request handler that returns the JSON program plan of a job graph.
|
class |
JobsOverviewHandler
Request handler that returns a summary of the job status.
|
class |
JobStoppingHandler
Request handler for the STOP request.
|
class |
JobVertexAccumulatorsHandler
Request handler that returns the accummulators for a given vertex.
|
class |
JobVertexBackPressureHandler
Request handler that returns back pressure stats for a single job vertex and
all its sub tasks.
|
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
A request handler that provides an overview over all taskmanagers or details for a single one.
|
Modifier and Type | Class and Description |
---|---|
class |
CheckpointConfigHandler
Handler that returns a job's snapshotting settings.
|
class |
CheckpointStatsDetailsHandler
Request handler that returns checkpoint stats for a single job vertex.
|
class |
CheckpointStatsDetailsSubtasksHandler
Request handler that returns checkpoint stats for a single job vertex with
the summary stats and all subtasks.
|
class |
CheckpointStatsHandler
Handler that returns checkpoint statistics for a job.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractMetricsHandler
Abstract request handler that returns a list of all available metrics or the values for a set of metrics.
|
class |
AggregatingJobsMetricsHandler
Request handler that returns, aggregated across all jobs, a list of all available metrics or the values
for a set of metrics.
|
class |
AggregatingSubtasksMetricsHandler
Request handler that returns, aggregated across all subtasks, a list of all available metrics or the values
for a set of metrics.
|
class |
AggregatingTaskManagersMetricsHandler
Request handler that returns, aggregated across all task managers, a list of all available metrics or the values for
a set of metrics.
|
class |
JobManagerMetricsHandler
Request handler that returns for the job manager a list of all available metrics or the values for a set of metrics.
|
class |
JobMetricsHandler
Request handler that returns for a given job a list of all available metrics or the values for a set of metrics.
|
class |
JobVertexMetricsHandler
Deprecated.
This class is subsumed by
SubtaskMetricsHandler and is only kept for backwards-compatibility. |
class |
SubtaskMetricsHandler
Request handler that returns, aggregated across all subtasks of a single tasks, a list of all available metrics or the
values for a set of metrics.
|
class |
TaskManagerMetricsHandler
Request handler that returns for a given task manager a list of all available metrics or the values for a set of metrics.
|
Constructor and Description |
---|
RuntimeMonitorHandler(WebMonitorConfig cfg,
RequestHandler handler,
GatewayRetriever<JobManagerGateway> retriever,
CompletableFuture<String> localJobManagerAddressFuture,
Time timeout) |
Modifier and Type | Class and Description |
---|---|
class |
JarAccessDeniedHandler
Handler to deny access to jar-related REST calls.
|
class |
JarActionHandler
Abstract handler for fetching plan for a jar or running a jar.
|
class |
JarDeleteHandler
Handles requests for deletion of jars.
|
class |
JarListHandler
Handle request for listing uploaded jars.
|
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.
|
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.