org.apache.iceberg.flink.util

Class ElapsedTimeGauge

java.lang.Object

org.apache.iceberg.flink.util.ElapsedTimeGauge

All Implemented Interfaces:

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

@Internal
public class ElapsedTimeGauge
extends java.lang.Object
implements org.apache.flink.metrics.Gauge<java.lang.Long>

This gauge measures the elapsed time between now and last recorded time set by refreshLastRecordedTime().

Constructor Summary

Constructors

Constructor and Description
ElapsedTimeGauge(java.util.concurrent.TimeUnit timeUnit)

Method Summary

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

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

ElapsedTimeGauge

public ElapsedTimeGauge(java.util.concurrent.TimeUnit timeUnit)

Method Detail

refreshLastRecordedTime

public void refreshLastRecordedTime()

getValue

public java.lang.Long getValue()

Specified by:

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