org.apache.beam.runners.flink.metrics

Class FlinkMetricContainer.FlinkGauge

java.lang.Object

org.apache.beam.runners.flink.metrics.FlinkMetricContainer.FlinkGauge

All Implemented Interfaces:

org.apache.flink.metrics.Gauge<java.lang.Long>, org.apache.flink.metrics.Metric

Enclosing class:

FlinkMetricContainer

public static class FlinkMetricContainer.FlinkGauge
extends java.lang.Object
implements org.apache.flink.metrics.Gauge<java.lang.Long>

Flink Gauge for GaugeResult.

Method Summary

Modifier and Type	Method and Description
java.lang.Long	getValue()

Methods inherited from class java.lang.Object

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

Method Detail

getValue

public java.lang.Long getValue()

Specified by:

getValue in interface org.apache.flink.metrics.Gauge<java.lang.Long>