public class MetricStore extends Object
Modifier and Type | Class and Description |
---|---|
static class |
MetricStore.JobManagerMetricStore
Sub-structure containing metrics of the JobManager.
|
static class |
MetricStore.JobMetricStore
Sub-structure containing metrics of a single Job.
|
static class |
MetricStore.SubtaskMetricStore
Sub-structure containing metrics of a single Subtask.
|
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() |
Modifier and Type | Method and Description |
---|---|
void |
add(MetricDump metric) |
MetricStore.JobManagerMetricStore |
getJobManagerMetricStore()
Returns the
MetricStore.JobManagerMetricStore . |
MetricStore.JobMetricStore |
getJobMetricStore(String jobID)
Returns the
MetricStore.JobMetricStore for the given job ID. |
MetricStore.SubtaskMetricStore |
getSubtaskMetricStore(String jobID,
String taskID,
int subtaskIndex)
Returns the
MetricStore.SubtaskMetricStore for the given job/task ID and subtask index. |
MetricStore.TaskManagerMetricStore |
getTaskManagerMetricStore(String tmID)
Returns the
MetricStore.TaskManagerMetricStore for the given taskmanager ID. |
MetricStore.TaskMetricStore |
getTaskMetricStore(String jobID,
String taskID)
Returns the
MetricStore.TaskMetricStore for the given job/task ID. |
public void add(MetricDump metric)
public MetricStore.JobManagerMetricStore getJobManagerMetricStore()
MetricStore.JobManagerMetricStore
.public MetricStore.TaskManagerMetricStore getTaskManagerMetricStore(String tmID)
MetricStore.TaskManagerMetricStore
for the given taskmanager ID.tmID
- taskmanager IDpublic MetricStore.JobMetricStore getJobMetricStore(String jobID)
MetricStore.JobMetricStore
for the given job ID.jobID
- job IDpublic MetricStore.TaskMetricStore getTaskMetricStore(String jobID, String taskID)
MetricStore.TaskMetricStore
for the given job/task ID.jobID
- job IDtaskID
- task IDpublic MetricStore.SubtaskMetricStore getSubtaskMetricStore(String jobID, String taskID, int subtaskIndex)
MetricStore.SubtaskMetricStore
for the given job/task ID and subtask index.jobID
- job IDtaskID
- task IDsubtaskIndex
- subtask indexCopyright © 2014–2018 The Apache Software Foundation. All rights reserved.