@ThreadSafe public class MetricStore extends Object
Modifier and Type | Class and Description |
---|---|
static class |
MetricStore.ComponentMetricStore
Structure containing metrics of a single component.
|
static class |
MetricStore.TaskManagerMetricStore
Sub-structure containing metrics of a single TaskManager.
|
static class |
MetricStore.TaskMetricStore
Sub-structure containing metrics of a single Task.
|
Constructor and Description |
---|
MetricStore() |
public MetricStore.ComponentMetricStore getJobManagerMetricStore()
MetricStore.ComponentMetricStore
for the JobManager.public MetricStore.TaskManagerMetricStore getTaskManagerMetricStore(String tmID)
MetricStore.TaskManagerMetricStore
for the given taskmanager ID.tmID
- taskmanager IDpublic MetricStore.ComponentMetricStore getJobMetricStore(String jobID)
MetricStore.ComponentMetricStore
for the given job ID.jobID
- job IDpublic MetricStore.TaskMetricStore getTaskMetricStore(String jobID, String taskID)
MetricStore.ComponentMetricStore
for the given job/task ID.jobID
- job IDtaskID
- task IDpublic MetricStore.ComponentMetricStore getSubtaskMetricStore(String jobID, String taskID, int subtaskIndex)
MetricStore.ComponentMetricStore
for the given job/task ID and subtask index.jobID
- job IDtaskID
- task IDsubtaskIndex
- subtask indexpublic Map<String,org.apache.flink.runtime.rest.handler.legacy.metrics.MetricStore.JobMetricStore> getJobs()
public Map<String,MetricStore.TaskManagerMetricStore> getTaskManagers()
@Deprecated public MetricStore.ComponentMetricStore getJobManager()
getJobManagerMetricStore()
.@VisibleForTesting public void add(MetricDump metric)
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.