Class DownTimeGauge
- java.lang.Object
-
- org.apache.flink.runtime.executiongraph.metrics.DownTimeGauge
-
public class DownTimeGauge extends Object implements Gauge<Long>
A gauge that returns (in milliseconds) how long a job has not been not running any more, in case it is in a failing/recovering situation. Running jobs return naturally a value of zero.For jobs that have never run (new not yet scheduled jobs) or jobs that have run again after failing, this gauge returns 0L, and for jobs that are not running any more, it returns -1L.
-
-
Field Summary
Fields Modifier and Type Field Description static String
METRIC_NAME
-
Constructor Summary
Constructors Constructor Description DownTimeGauge(JobStatusProvider jobStatusProvider)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Long
getValue()
Calculates and returns the measured value.-
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
-
-
-
-
Field Detail
-
METRIC_NAME
public static final String METRIC_NAME
- See Also:
- Constant Field Values
-
-
Constructor Detail
-
DownTimeGauge
public DownTimeGauge(JobStatusProvider jobStatusProvider)
-
-