org.apache.flink.runtime.executiongraph.metrics

Class RestartTimeGauge

java.lang.Object

org.apache.flink.runtime.executiongraph.metrics.RestartTimeGauge

All Implemented Interfaces:

Gauge<Long>, Metric

public class RestartTimeGauge
extends Object
implements Gauge<Long>

Gauge which returns the last restarting time.

Restarting time is the time between JobStatus.RESTARTING and JobStatus.RUNNING, or a terminal state if JobStatus.RUNNING was not reached.

If the job has not yet reached either of these states, then the time is measured since reaching JobStatus.RESTARTING. If it is still the initial job execution, then the gauge will return 0.

Field Summary

Fields

Modifier and Type	Field and Description
static String	METRIC_NAME

Constructor Summary

Constructors

Constructor and Description
RestartTimeGauge(JobStatusProvider jobStatusProvider)

Method Summary

Modifier and Type	Method and 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

Field Detail

METRIC_NAME

public static final String METRIC_NAME

See Also:

Constant Field Values

Constructor Detail

RestartTimeGauge

public RestartTimeGauge(JobStatusProvider jobStatusProvider)

Method Detail

getValue

public Long getValue()

Description copied from interface: Gauge

Calculates and returns the measured value.

Specified by:

getValue in interface Gauge<Long>

Returns:

calculated value