org.apache.flink.python.metric.process

Class FlinkMetricContainer.FlinkDistributionGauge

java.lang.Object

org.apache.flink.python.metric.process.FlinkMetricContainer.FlinkDistributionGauge

All Implemented Interfaces:

Gauge<org.apache.beam.sdk.metrics.DistributionResult>, Metric

Enclosing class:

FlinkMetricContainer

public static class FlinkMetricContainer.FlinkDistributionGauge
extends Object
implements Gauge<org.apache.beam.sdk.metrics.DistributionResult>

Flink Gauge for DistributionResult.

Method Summary

Modifier and Type	Method and Description
org.apache.beam.sdk.metrics.DistributionResult	getValue() Calculates and returns the measured value.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.metrics.Gauge

getMetricType

Method Detail

getValue

public org.apache.beam.sdk.metrics.DistributionResult getValue()

Description copied from interface: Gauge

Calculates and returns the measured value.

Specified by:

getValue in interface Gauge<org.apache.beam.sdk.metrics.DistributionResult>

Returns:

calculated value