@Internal public class TaskManagerJobMetricGroup extends JobMetricGroup<TaskManagerMetricGroup>
MetricGroup
representing everything belonging to a
specific job, running on the TaskManager.
Contains extra logic for adding Tasks (TaskMetricGroup
).
AbstractMetricGroup.ChildType
jobId, jobName
LOG, parent, queryServiceScopeInfo, registry, variables
Modifier and Type | Method and Description |
---|---|
TaskMetricGroup |
addTask(JobVertexID jobVertexId,
ExecutionAttemptID executionAttemptID,
String taskName,
int subtaskIndex,
int attemptNumber) |
TaskManagerMetricGroup |
parent() |
void |
removeTaskMetricGroup(ExecutionAttemptID executionId) |
protected Iterable<? extends ComponentMetricGroup> |
subComponents()
Gets all component metric groups that are contained in this component metric group.
|
createQueryServiceMetricInfo, getGroupName, jobId, jobName, putVariables
close
addGroup, addGroup, addMetric, counter, counter, createChildGroup, createLogicalScope, gauge, getAllVariables, getAllVariables, getLogicalScope, getLogicalScope, getMetricIdentifier, getMetricIdentifier, getMetricIdentifier, getQueryServiceMetricInfo, getScopeComponents, histogram, isClosed, meter
public final TaskManagerMetricGroup parent()
public TaskMetricGroup addTask(JobVertexID jobVertexId, ExecutionAttemptID executionAttemptID, String taskName, int subtaskIndex, int attemptNumber)
public void removeTaskMetricGroup(ExecutionAttemptID executionId)
protected Iterable<? extends ComponentMetricGroup> subComponents()
ComponentMetricGroup
subComponents
in class ComponentMetricGroup<TaskManagerMetricGroup>
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.