Class ElapsedTimeGauge

  • All Implemented Interfaces:
    org.apache.flink.metrics.Gauge<java.lang.Long>, org.apache.flink.metrics.Metric

    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

      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

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