org.apache.flink.metrics.testutils

类 MetricListener

java.lang.Object

org.apache.flink.metrics.testutils.MetricListener

public class MetricListener
extends Object

A MetricListener listens metric and group registration under the provided root metric group, and stores them in an internal HashMap for fetching.

字段概要

字段

限定符和类型	字段和说明
static String	DELIMITER
static String	ROOT_METRIC_GROUP_NAME

构造器概要

构造器

构造器和说明
MetricListener()

方法概要

限定符和类型	方法和说明
Optional<org.apache.flink.metrics.Counter>	getCounter(String... identifier) Get registered Counter with identifier relative to the root metric group.
<T> Optional<org.apache.flink.metrics.Gauge<T>>	getGauge(String... identifier) Get registered Gauge with identifier relative to the root metric group.
Optional<org.apache.flink.metrics.Histogram>	getHistogram(String... identifier) Get registered Histogram with identifier relative to the root metric group.
Optional<org.apache.flink.metrics.Meter>	getMeter(String... identifier) Get registered Meter with identifier relative to the root metric group.
<T extends org.apache.flink.metrics.Metric> Optional<T>	getMetric(Class<T> metricType, String... identifier) Get registered Metric with identifier relative to the root metric group.
org.apache.flink.metrics.MetricGroup	getMetricGroup() Get the root metric group of this listener.

从类继承的方法 java.lang.Object

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

字段详细资料

DELIMITER

public static final String DELIMITER

另请参阅:

常量字段值

ROOT_METRIC_GROUP_NAME

public static final String ROOT_METRIC_GROUP_NAME

另请参阅:

常量字段值

构造器详细资料

MetricListener

public MetricListener()

方法详细资料

getMetricGroup

public org.apache.flink.metrics.MetricGroup getMetricGroup()

Get the root metric group of this listener. Note that only metrics and groups registered under this group will be listened.

返回:

Root metric group

getMetric

public <T extends org.apache.flink.metrics.Metric> Optional<T> getMetric(Class<T> metricType,
                                                                         String... identifier)

Get registered Metric with identifier relative to the root metric group.

For example, identifier of metric "myMetric" registered in group "myGroup" under root metric group can be reached by identifier ("myGroup", "myMetric")

参数:

identifier - identifier relative to the root metric group

返回:

Optional registered metric

getMeter

public Optional<org.apache.flink.metrics.Meter> getMeter(String... identifier)

Get registered Meter with identifier relative to the root metric group.

参数:

identifier - identifier relative to the root metric group

返回:

Optional registered meter

getCounter

public Optional<org.apache.flink.metrics.Counter> getCounter(String... identifier)

Get registered Counter with identifier relative to the root metric group.

参数:

identifier - identifier relative to the root metric group

返回:

Optional registered counter

getHistogram

public Optional<org.apache.flink.metrics.Histogram> getHistogram(String... identifier)

Get registered Histogram with identifier relative to the root metric group.

参数:

identifier - identifier relative to the root metric group

返回:

Optional registered histogram

getGauge

public <T> Optional<org.apache.flink.metrics.Gauge<T>> getGauge(String... identifier)

Get registered Gauge with identifier relative to the root metric group.

参数:

identifier - identifier relative to the root metric group

返回:

Optional registered gauge