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 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>