Package org.apache.iceberg.flink.util

Class ElapsedTimeGauge

java.lang.Object

org.apache.iceberg.flink.util.ElapsedTimeGauge

All Implemented Interfaces:

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

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

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

Constructor Summary

Constructors

Constructor	Description
ElapsedTimeGauge(TimeUnit timeUnit)

Method Summary

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

ElapsedTimeGauge

public ElapsedTimeGauge(TimeUnit timeUnit)

Method Details

refreshLastRecordedTime

public void refreshLastRecordedTime()

getValue

public Long getValue()

Specified by:

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