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 Details
-
ElapsedTimeGauge
-
-
Method Details
-
refreshLastRecordedTime
public void refreshLastRecordedTime() -
getValue
- Specified by:
getValue
in interfaceorg.apache.flink.metrics.Gauge<Long>
-