public class TaskMetricGroup extends ComponentMetricGroup
MetricGroup
representing a Flink runtime Task.
Contains extra logic for adding operators.
registry
Constructor and Description |
---|
TaskMetricGroup(MetricRegistry registry,
TaskManagerJobMetricGroup parent,
AbstractID vertexId,
AbstractID executionId,
String taskName,
int subtaskIndex,
int attemptNumber) |
TaskMetricGroup(MetricRegistry registry,
TaskManagerJobMetricGroup parent,
TaskScopeFormat scopeFormat,
AbstractID vertexId,
AbstractID executionId,
String taskName,
int subtaskIndex,
int attemptNumber) |
Modifier and Type | Method and Description |
---|---|
OperatorMetricGroup |
addOperator(String name) |
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. |
AbstractID |
executionId() |
IOMetricGroup |
getIOMetricGroup()
Returns the IOMetricGroup for this task.
|
TaskManagerJobMetricGroup |
parent() |
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, counter, counter, gauge, gauge, getMetricIdentifier, getMetricIdentifier, getScopeComponents, histogram, histogram, isClosed
public TaskMetricGroup(MetricRegistry registry, TaskManagerJobMetricGroup parent, @Nullable AbstractID vertexId, AbstractID executionId, @Nullable String taskName, int subtaskIndex, int attemptNumber)
public TaskMetricGroup(MetricRegistry registry, TaskManagerJobMetricGroup parent, TaskScopeFormat scopeFormat, @Nullable AbstractID vertexId, AbstractID executionId, @Nullable String taskName, int subtaskIndex, int attemptNumber)
public final TaskManagerJobMetricGroup parent()
public AbstractID executionId()
@Nullable public AbstractID vertexId()
public int subtaskIndex()
public int attemptNumber()
public IOMetricGroup getIOMetricGroup()
public OperatorMetricGroup addOperator(String name)
public void close()
ComponentMetricGroup
AbstractMetricGroup
), plus closing and removing all dedicated
component subgroups.close
in class ComponentMetricGroup
protected Iterable<? extends ComponentMetricGroup> subComponents()
ComponentMetricGroup
subComponents
in class ComponentMetricGroup
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.