Package | Description |
---|---|
org.apache.flink.runtime.rest.handler.legacy | |
org.apache.flink.runtime.rest.handler.legacy.metrics | |
org.apache.flink.runtime.rest.handler.util |
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(ExecutionGraphCache executionGraphHolder,
Executor executor,
MetricFetcher fetcher) |
JobVertexDetailsHandler(ExecutionGraphCache executionGraphHolder,
Executor executor,
MetricFetcher fetcher) |
JobVertexTaskManagersHandler(ExecutionGraphCache executionGraphHolder,
Executor executor,
MetricFetcher fetcher) |
SubtaskCurrentAttemptDetailsHandler(ExecutionGraphCache executionGraphHolder,
Executor executor,
MetricFetcher fetcher) |
SubtaskExecutionAttemptDetailsHandler(ExecutionGraphCache executionGraphHolder,
Executor executor,
MetricFetcher fetcher) |
TaskManagersHandler(Executor executor,
Time timeout,
MetricFetcher fetcher) |
Constructor and Description |
---|
AbstractMetricsHandler(Executor executor,
MetricFetcher fetcher) |
AggregatingJobsMetricsHandler(Executor executor,
MetricFetcher fetcher) |
AggregatingSubtasksMetricsHandler(Executor executor,
MetricFetcher fetcher) |
AggregatingTaskManagersMetricsHandler(Executor executor,
MetricFetcher fetcher) |
JobManagerMetricsHandler(Executor executor,
MetricFetcher fetcher) |
JobMetricsHandler(Executor executor,
MetricFetcher fetcher) |
JobVertexMetricsHandler(Executor executor,
MetricFetcher fetcher)
Deprecated.
|
SubtaskMetricsHandler(Executor executor,
MetricFetcher fetcher) |
TaskManagerMetricsHandler(Executor executor,
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.