org.apache.flink.runtime.metrics.groups

Class FrontMetricGroup<P extends AbstractMetricGroup<?>>

java.lang.Object

org.apache.flink.runtime.metrics.groups.ProxyMetricGroup<P>

org.apache.flink.runtime.metrics.groups.FrontMetricGroup<P>

Type Parameters:

P - parentMetricGroup to AbstractMetricGroup

All Implemented Interfaces:

MetricGroup

public class FrontMetricGroup<P extends AbstractMetricGroup<?>>
extends ProxyMetricGroup<P>

Metric group which forwards all registration calls to a variable parent metric group that injects a variable reporter index into calls to MetricGroup.getMetricIdentifier(String) or MetricGroup.getMetricIdentifier(String, CharacterFilter). This allows us to use reporter-specific delimiters, without requiring any action by the reporter.

Field Summary

Fields

Modifier and Type	Field and Description
protected int	reporterIndex

Fields inherited from class org.apache.flink.runtime.metrics.groups.ProxyMetricGroup

parentMetricGroup

Constructor Summary

Constructors

Constructor and Description
FrontMetricGroup(int reporterIndex, P reference)

Method Summary

Modifier and Type	Method and Description
String	getLogicalScope(CharacterFilter filter)
String	getLogicalScope(CharacterFilter filter, char delimiter)
String	getMetricIdentifier(String metricName) Returns the fully qualified metric name, for example "host-7.taskmanager-2.window_word_count.my-mapper.metricName".
String	getMetricIdentifier(String metricName, CharacterFilter filter) Returns the fully qualified metric name, for example "host-7.taskmanager-2.window_word_count.my-mapper.metricName".

Methods inherited from class org.apache.flink.runtime.metrics.groups.ProxyMetricGroup

addGroup, addGroup, addGroup, counter, counter, counter, counter, gauge, gauge, getAllVariables, getScopeComponents, histogram, histogram, meter, meter

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

reporterIndex

protected int reporterIndex

Constructor Detail

FrontMetricGroup

public FrontMetricGroup(int reporterIndex,
                        P reference)

Method Detail

getMetricIdentifier

public String getMetricIdentifier(String metricName)

Description copied from interface: MetricGroup

Returns the fully qualified metric name, for example "host-7.taskmanager-2.window_word_count.my-mapper.metricName".

Specified by:

getMetricIdentifier in interface MetricGroup

Overrides:

getMetricIdentifier in class ProxyMetricGroup<P extends AbstractMetricGroup<?>>

Parameters:

metricName - metric name

Returns:

fully qualified metric name

getMetricIdentifier

public String getMetricIdentifier(String metricName,
                                  CharacterFilter filter)

Description copied from interface: MetricGroup

Returns the fully qualified metric name, for example "host-7.taskmanager-2.window_word_count.my-mapper.metricName".

Specified by:

getMetricIdentifier in interface MetricGroup

Overrides:

getMetricIdentifier in class ProxyMetricGroup<P extends AbstractMetricGroup<?>>

Parameters:

metricName - metric name

filter - character filter which is applied to the scope components if not null.

Returns:

fully qualified metric name

getLogicalScope

public String getLogicalScope(CharacterFilter filter)

getLogicalScope

public String getLogicalScope(CharacterFilter filter,
                              char delimiter)