@Internal public class TaskMetricGroup extends ComponentMetricGroup<TaskManagerJobMetricGroup>
MetricGroup
representing a Flink runtime Task.
Contains extra logic for adding operators.
AbstractMetricGroup.ChildType
Modifier and Type | Field and Description |
---|---|
protected int |
subtaskIndex |
protected JobVertexID |
vertexId |
LOG, parent, queryServiceScopeInfo, registry, variables
Constructor and Description |
---|
TaskMetricGroup(MetricRegistry registry,
TaskManagerJobMetricGroup parent,
JobVertexID vertexId,
ExecutionAttemptID executionId,
String taskName,
int subtaskIndex,
int attemptNumber) |
Modifier and Type | Method and Description |
---|---|
int |
attemptNumber() |
void |
close()
Closes the component group by removing and closing all metrics and subgroups (inherited from
AbstractMetricGroup ), plus closing and removing all dedicated component subgroups. |
protected QueryScopeInfo.TaskQueryScopeInfo |
createQueryServiceMetricInfo(CharacterFilter filter)
Creates the metric query service scope for this group.
|
ExecutionAttemptID |
executionId() |
protected String |
getGroupName(CharacterFilter filter)
Returns the name for this group, meaning what kind of entity it represents, for example
"taskmanager".
|
TaskIOMetricGroup |
getIOMetricGroup()
Returns the TaskIOMetricGroup for this task.
|
OperatorMetricGroup |
getOrAddOperator(OperatorID operatorID,
String operatorName) |
OperatorMetricGroup |
getOrAddOperator(String operatorName) |
TaskManagerJobMetricGroup |
parent() |
protected void |
putVariables(Map<String,String> variables)
Enters all variables specific to this
AbstractMetricGroup and their associated values
into the map. |
protected Iterable<? extends ComponentMetricGroup> |
subComponents()
Gets all component metric groups that are contained in this component metric group.
|
int |
subtaskIndex() |
String |
taskName() |
AbstractID |
vertexId() |
addGroup, addGroup, addMetric, counter, counter, createChildGroup, createLogicalScope, gauge, getAllVariables, getAllVariables, getLogicalScope, getLogicalScope, getMetricIdentifier, getMetricIdentifier, getMetricIdentifier, getQueryServiceMetricInfo, getScopeComponents, histogram, isClosed, meter
protected final JobVertexID vertexId
protected final int subtaskIndex
public TaskMetricGroup(MetricRegistry registry, TaskManagerJobMetricGroup parent, JobVertexID vertexId, ExecutionAttemptID executionId, String taskName, int subtaskIndex, int attemptNumber)
public final TaskManagerJobMetricGroup parent()
public ExecutionAttemptID executionId()
@Nullable public AbstractID vertexId()
public int subtaskIndex()
public int attemptNumber()
public TaskIOMetricGroup getIOMetricGroup()
protected QueryScopeInfo.TaskQueryScopeInfo createQueryServiceMetricInfo(CharacterFilter filter)
AbstractMetricGroup
createQueryServiceMetricInfo
in class AbstractMetricGroup<TaskManagerJobMetricGroup>
filter
- character filterpublic OperatorMetricGroup getOrAddOperator(String operatorName)
public OperatorMetricGroup getOrAddOperator(OperatorID operatorID, String operatorName)
public void close()
ComponentMetricGroup
AbstractMetricGroup
), plus closing and removing all dedicated component subgroups.close
in class ComponentMetricGroup<TaskManagerJobMetricGroup>
protected void putVariables(Map<String,String> variables)
AbstractMetricGroup
AbstractMetricGroup
and their associated values
into the map.putVariables
in class AbstractMetricGroup<TaskManagerJobMetricGroup>
variables
- map to enter variables and their values intoprotected Iterable<? extends ComponentMetricGroup> subComponents()
ComponentMetricGroup
subComponents
in class ComponentMetricGroup<TaskManagerJobMetricGroup>
protected String getGroupName(CharacterFilter filter)
AbstractMetricGroup
getGroupName
in class AbstractMetricGroup<TaskManagerJobMetricGroup>
filter
- character filter which is applied to the nameCopyright © 2014–2022 The Apache Software Foundation. All rights reserved.