org.apache.flink.streaming.api.operators

Class AbstractStreamOperator.LatencyGauge

java.lang.Object

org.apache.flink.streaming.api.operators.AbstractStreamOperator.LatencyGauge

All Implemented Interfaces:

Gauge<Map<String,HashMap<String,Double>>>, Metric

Enclosing class:

AbstractStreamOperator<OUT>

protected static class AbstractStreamOperator.LatencyGauge
extends Object
implements Gauge<Map<String,HashMap<String,Double>>>

The gauge uses a HashMap internally to avoid classloading issues when accessing the values using JMX.

Method Summary

Modifier and Type	Method and Description
Map<String,HashMap<String,Double>>	getValue() Calculates and returns the measured value.
void	reportLatency(LatencyMarker marker, boolean isSink)

Methods inherited from class java.lang.Object

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

Method Detail

reportLatency

public void reportLatency(LatencyMarker marker,
                          boolean isSink)

getValue

public Map<String,HashMap<String,Double>> getValue()

Description copied from interface: Gauge

Calculates and returns the measured value.

Specified by:

getValue in interface Gauge<Map<String,HashMap<String,Double>>>

Returns:

calculated value