public class JobManagerMetricGroup extends ComponentMetricGroup<JobManagerMetricGroup>
MetricGroup
representing a JobManager.
Contains extra logic for adding jobs with tasks, and removing jobs when they do not contain tasks any more
LOG, parent, queryServiceScopeInfo, registry, variables
Constructor and Description |
---|
JobManagerMetricGroup(MetricRegistry registry,
String hostname) |
Modifier and Type | Method and Description |
---|---|
JobManagerJobMetricGroup |
addJob(JobGraph job) |
protected QueryScopeInfo.JobManagerQueryScopeInfo |
createQueryServiceMetricInfo(CharacterFilter filter)
Creates the metric query service scope for this group.
|
protected String |
getGroupName(CharacterFilter filter)
Returns the name for this group, meaning what kind of entity it represents, for example "taskmanager".
|
String |
hostname() |
int |
numRegisteredJobMetricGroups() |
protected void |
putVariables(Map<String,String> variables)
Enters all variables specific to this ComponentMetricGroup and their associated values into the map.
|
void |
removeJob(JobID jobId) |
protected Iterable<? extends ComponentMetricGroup> |
subComponents()
Gets all component metric groups that are contained in this component metric group.
|
close, getAllVariables
addGroup, addGroup, addMetric, counter, counter, counter, counter, gauge, gauge, getLogicalScope, getLogicalScope, getMetricIdentifier, getMetricIdentifier, getMetricIdentifier, getQueryServiceMetricInfo, getScopeComponents, histogram, histogram, isClosed, meter, meter
public JobManagerMetricGroup(MetricRegistry registry, String hostname)
public String hostname()
protected QueryScopeInfo.JobManagerQueryScopeInfo createQueryServiceMetricInfo(CharacterFilter filter)
AbstractMetricGroup
createQueryServiceMetricInfo
in class AbstractMetricGroup<JobManagerMetricGroup>
filter
- character filterpublic JobManagerJobMetricGroup addJob(JobGraph job)
public void removeJob(JobID jobId)
public int numRegisteredJobMetricGroups()
protected void putVariables(Map<String,String> variables)
ComponentMetricGroup
putVariables
in class ComponentMetricGroup<JobManagerMetricGroup>
variables
- map to enter variables and their values intoprotected Iterable<? extends ComponentMetricGroup> subComponents()
ComponentMetricGroup
subComponents
in class ComponentMetricGroup<JobManagerMetricGroup>
protected String getGroupName(CharacterFilter filter)
AbstractMetricGroup
getGroupName
in class AbstractMetricGroup<JobManagerMetricGroup>
filter
- character filter which is applied to the nameCopyright © 2014–2018 The Apache Software Foundation. All rights reserved.