public class TaskManagerJobMetricGroup extends JobMetricGroup
MetricGroup
representing everything belonging to
a specific job, running on the TaskManager.
Contains extra logic for adding Tasks (TaskMetricGroup
).
jobId, jobName
registry
Constructor and Description |
---|
TaskManagerJobMetricGroup(MetricRegistry registry,
TaskManagerMetricGroup parent,
JobID jobId,
String jobName) |
TaskManagerJobMetricGroup(MetricRegistry registry,
TaskManagerMetricGroup parent,
TaskManagerJobScopeFormat scopeFormat,
JobID jobId,
String jobName) |
Modifier and Type | Method and Description |
---|---|
TaskMetricGroup |
addTask(JobVertexID jobVertexId,
ExecutionAttemptID executionAttemptID,
String taskName,
int subtaskIndex,
int attemptNumber) |
TaskManagerMetricGroup |
parent() |
void |
removeTaskMetricGroup(AbstractID executionId) |
protected Iterable<? extends ComponentMetricGroup> |
subComponents()
Gets all component metric groups that are contained in this component metric group.
|
jobId, jobName
close
addGroup, addGroup, addMetric, counter, counter, counter, counter, gauge, gauge, getMetricIdentifier, getMetricIdentifier, getScopeComponents, histogram, histogram, isClosed
public TaskManagerJobMetricGroup(MetricRegistry registry, TaskManagerMetricGroup parent, JobID jobId, @Nullable String jobName)
public TaskManagerJobMetricGroup(MetricRegistry registry, TaskManagerMetricGroup parent, TaskManagerJobScopeFormat scopeFormat, JobID jobId, @Nullable String jobName)
public final TaskManagerMetricGroup parent()
public TaskMetricGroup addTask(JobVertexID jobVertexId, ExecutionAttemptID executionAttemptID, String taskName, int subtaskIndex, int attemptNumber)
public void removeTaskMetricGroup(AbstractID executionId)
protected Iterable<? extends ComponentMetricGroup> subComponents()
ComponentMetricGroup
subComponents
in class ComponentMetricGroup
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.