Package | Description |
---|---|
org.apache.flink.runtime.webmonitor.handlers | |
org.apache.flink.runtime.webmonitor.metrics | |
org.apache.flink.runtime.webmonitor.utils |
Modifier and Type | Method and Description |
---|---|
static String |
SubtaskExecutionAttemptDetailsHandler.createAttemptDetailsJson(AccessExecution execAttempt,
String jobID,
String vertexID,
MetricFetcher fetcher) |
static String |
JobDetailsHandler.createJobDetailsJson(AccessExecutionGraph graph,
MetricFetcher fetcher) |
static String |
JobVertexTaskManagersHandler.createVertexDetailsByTaskManagerJson(AccessExecutionJobVertex jobVertex,
String jobID,
MetricFetcher fetcher) |
static String |
JobVertexDetailsHandler.createVertexDetailsJson(AccessExecutionJobVertex jobVertex,
String jobID,
MetricFetcher fetcher) |
Constructor and Description |
---|
JobDetailsHandler(ExecutionGraphHolder executionGraphHolder,
MetricFetcher fetcher) |
JobVertexDetailsHandler(ExecutionGraphHolder executionGraphHolder,
MetricFetcher fetcher) |
JobVertexTaskManagersHandler(ExecutionGraphHolder executionGraphHolder,
MetricFetcher fetcher) |
SubtaskCurrentAttemptDetailsHandler(ExecutionGraphHolder executionGraphHolder,
MetricFetcher fetcher) |
SubtaskExecutionAttemptDetailsHandler(ExecutionGraphHolder executionGraphHolder,
MetricFetcher fetcher) |
TaskManagersHandler(scala.concurrent.duration.FiniteDuration timeout,
MetricFetcher fetcher) |
Constructor and Description |
---|
AbstractMetricsHandler(MetricFetcher fetcher) |
JobManagerMetricsHandler(MetricFetcher fetcher) |
JobMetricsHandler(MetricFetcher fetcher) |
JobVertexMetricsHandler(MetricFetcher fetcher) |
TaskManagerMetricsHandler(MetricFetcher fetcher) |
Modifier and Type | Method and Description |
---|---|
void |
MutableIOMetrics.addIOMetrics(AccessExecution attempt,
MetricFetcher fetcher,
String jobID,
String taskID)
Adds the IO metrics for the given attempt to this object.
|
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.