org.apache.flink.metrics

Interface MetricGroup

All Known Implementing Classes:

UnregisteredMetricsGroup

public interface MetricGroup

A MetricGroup is a named container for Metrics and further metric subgroups.

Instances of this class can be used to register new metrics with Flink and to create a nested hierarchy based on the group names.

A MetricGroup is uniquely identified by it's place in the hierarchy and name.

Method Summary

Modifier and Type	Method and Description
MetricGroup	addGroup(int name) Creates a new MetricGroup and adds it to this groups sub-groups.
MetricGroup	addGroup(String name) Creates a new MetricGroup and adds it to this groups sub-groups.
Counter	counter(int name) Creates and registers a new Counter with Flink.
<C extends Counter> C	counter(int name, C counter) Registers a Counter with Flink.
Counter	counter(String name) Creates and registers a new Counter with Flink.
<C extends Counter> C	counter(String name, C counter) Registers a Counter with Flink.
<T,G extends Gauge<T>> G	gauge(int name, G gauge) Registers a new Gauge with Flink.
<T,G extends Gauge<T>> G	gauge(String name, G gauge) Registers a new Gauge with Flink.
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"
String[]	getScopeComponents() Gets the scope as an array of the scope components, for example ["host-7", "taskmanager-2", "window_word_count", "my-mapper"]
<H extends Histogram> H	histogram(int name, H histogram) Registers a new Histogram with Flink.
<H extends Histogram> H	histogram(String name, H histogram) Registers a new Histogram with Flink.

Method Detail

counter

Counter counter(int name)

Creates and registers a new Counter with Flink.

Parameters:

name - name of the counter

Returns:

the created counter

counter

Counter counter(String name)

Creates and registers a new Counter with Flink.

Parameters:

name - name of the counter

Returns:

the created counter

counter

<C extends Counter> C counter(int name,
                              C counter)

Registers a Counter with Flink.

Type Parameters:

C - counter type

Parameters:

name - name of the counter

counter - counter to register

Returns:

the given counter

counter

<C extends Counter> C counter(String name,
                              C counter)

Registers a Counter with Flink.

Type Parameters:

C - counter type

Parameters:

name - name of the counter

counter - counter to register

Returns:

the given counter

gauge

<T,G extends Gauge<T>> G gauge(int name,
                               G gauge)

Registers a new Gauge with Flink.

Type Parameters:

T - return type of the gauge

Parameters:

name - name of the gauge

gauge - gauge to register

Returns:

the given gauge

gauge

<T,G extends Gauge<T>> G gauge(String name,
                               G gauge)

Registers a new Gauge with Flink.

Type Parameters:

T - return type of the gauge

Parameters:

name - name of the gauge

gauge - gauge to register

Returns:

the given gauge

histogram

<H extends Histogram> H histogram(String name,
                                  H histogram)

Registers a new Histogram with Flink.

Type Parameters:

H - histogram type

Parameters:

name - name of the histogram

histogram - histogram to register

Returns:

the registered histogram

histogram

<H extends Histogram> H histogram(int name,
                                  H histogram)

Registers a new Histogram with Flink.

Type Parameters:

H - histogram type

Parameters:

name - name of the histogram

histogram - histogram to register

Returns:

the registered histogram

addGroup

MetricGroup addGroup(int name)

Creates a new MetricGroup and adds it to this groups sub-groups.

Parameters:

name - name of the group

Returns:

the created group

addGroup

MetricGroup addGroup(String name)

Creates a new MetricGroup and adds it to this groups sub-groups.

Parameters:

name - name of the group

Returns:

the created group

getScopeComponents

String[] getScopeComponents()

Gets the scope as an array of the scope components, for example ["host-7", "taskmanager-2", "window_word_count", "my-mapper"]

See Also:

getMetricIdentifier(String), getMetricIdentifier(String, CharacterFilter)

getMetricIdentifier

String getMetricIdentifier(String metricName)

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

Parameters:

metricName - metric name

Returns:

fully qualified metric name

getMetricIdentifier

String getMetricIdentifier(String metricName,
                           CharacterFilter filter)

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

Parameters:

metricName - metric name

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

Returns:

fully qualified metric name