Package org.apache.flink.runtime.scheduler.metrics

Class AllSubTasksRunningOrFinishedStateTimeMetrics

java.lang.Object

org.apache.flink.runtime.scheduler.metrics.AllSubTasksRunningOrFinishedStateTimeMetrics

All Implemented Interfaces:

ExecutionStateUpdateListener, ExecutionStatusMetricsRegistrar, MetricsRegistrar, StateTimeMetric

public class AllSubTasksRunningOrFinishedStateTimeMetrics
extends Object
implements ExecutionStatusMetricsRegistrar, StateTimeMetric

Metrics and event that captures how long a job has all it's subtask in running or finished state.

This is only interesting for streaming jobs, and we don't register for batch.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	AllSubTasksRunningOrFinishedStateTimeMetrics.Status

Field Summary

Fields

Modifier and Type	Field	Description
static String	STATUS_ATTRIBUTE

Constructor Summary

Constructors

Constructor	Description
AllSubTasksRunningOrFinishedStateTimeMetrics(JobType semantic, org.apache.flink.configuration.MetricOptions.JobStatusMetricsSettings stateTimeMetricsSettings)

Method Summary

Modifier and Type	Method	Description
long	getBinary()	Returns 1 if we are in the targeted state, otherwise 0.
long	getCurrentTime()	Returns the time, in milliseconds, that have elapsed since we transitioned to the targeted state.
long	getTotalTime()	Returns the total time, in milliseconds, that we have spent in the targeted state.
void	onStateUpdate(ExecutionAttemptID execution, ExecutionState previousState, ExecutionState newState)
void	onStateUpdate(Execution execution, ExecutionState previousState, ExecutionState newState)
void	registerMetrics(org.apache.flink.metrics.MetricGroup metricGroup)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

STATUS_ATTRIBUTE

public static final String STATUS_ATTRIBUTE

See Also:

Constant Field Values

Constructor Detail

AllSubTasksRunningOrFinishedStateTimeMetrics

public AllSubTasksRunningOrFinishedStateTimeMetrics(JobType semantic,
                                                    org.apache.flink.configuration.MetricOptions.JobStatusMetricsSettings stateTimeMetricsSettings)

Method Detail

getCurrentTime

public long getCurrentTime()

Description copied from interface: StateTimeMetric

Returns the time, in milliseconds, that have elapsed since we transitioned to the targeted state. Returns 0 if we are not in the targeted state.

Specified by:

getCurrentTime in interface StateTimeMetric

getTotalTime

public long getTotalTime()

Description copied from interface: StateTimeMetric

Returns the total time, in milliseconds, that we have spent in the targeted state.

Specified by:

getTotalTime in interface StateTimeMetric

getBinary

public long getBinary()

Description copied from interface: StateTimeMetric

Returns 1 if we are in the targeted state, otherwise 0.

Specified by:

getBinary in interface StateTimeMetric

registerMetrics

public void registerMetrics(org.apache.flink.metrics.MetricGroup metricGroup)

Specified by:

registerMetrics in interface MetricsRegistrar

onStateUpdate

public void onStateUpdate(Execution execution,
                          ExecutionState previousState,
                          ExecutionState newState)

onStateUpdate

public void onStateUpdate(ExecutionAttemptID execution,
                          ExecutionState previousState,
                          ExecutionState newState)

Specified by:

onStateUpdate in interface ExecutionStateUpdateListener