Package org.apache.iceberg.flink.util

Class 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 Description
      ElapsedTimeGauge​(java.util.concurrent.TimeUnit timeUnit)  

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method 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>