org.apache.flink.runtime.io.network.metrics

Class TimeToConsumeGauge

java.lang.Object

org.apache.flink.runtime.io.network.metrics.TimeToConsumeGauge

All Implemented Interfaces:

Gauge<Long>, Metric

public class TimeToConsumeGauge
extends Object
implements Gauge<Long>

Gauge metric measuring the maximal time to consume all buffers of all input gates.

Constructor Summary

Constructors

Constructor and Description
TimeToConsumeGauge(SingleInputGate[] gates)

Method Summary

Modifier and Type	Method and Description
Long	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

Constructor Detail

TimeToConsumeGauge

public TimeToConsumeGauge(SingleInputGate[] gates)

Method Detail

getValue

public Long getValue()

Description copied from interface: Gauge

Calculates and returns the measured value.

Specified by:

getValue in interface Gauge<Long>

Returns:

calculated value