org.apache.flink.runtime.scheduler.metrics

Class JobStatusMetrics

java.lang.Object

org.apache.flink.runtime.scheduler.metrics.JobStatusMetrics

All Implemented Interfaces:

JobStatusListener, MetricsRegistrar

public class JobStatusMetrics
extends Object
implements JobStatusListener, MetricsRegistrar

Metrics that capture the time that a job spends in each JobStatus.

Constructor Summary

Constructors

Constructor and Description
JobStatusMetrics(long initializationTimestamp, MetricOptions.JobStatusMetricsSettings jobStatusMetricsSettings)

Method Summary

Modifier and Type	Method and Description
void	jobStatusChanges(JobID jobId, JobStatus newJobStatus, long timestamp) This method is called whenever the status of the job changes.
void	registerMetrics(MetricGroup metricGroup)

Methods inherited from class java.lang.Object

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

Constructor Detail

JobStatusMetrics

public JobStatusMetrics(long initializationTimestamp,
                        MetricOptions.JobStatusMetricsSettings jobStatusMetricsSettings)

Method Detail

registerMetrics

public void registerMetrics(MetricGroup metricGroup)

Specified by:

registerMetrics in interface MetricsRegistrar

jobStatusChanges

public void jobStatusChanges(JobID jobId,
                             JobStatus newJobStatus,
                             long timestamp)

Description copied from interface: JobStatusListener

This method is called whenever the status of the job changes.

Specified by:

jobStatusChanges in interface JobStatusListener

Parameters:

jobId - The ID of the job.

newJobStatus - The status the job switched to.

timestamp - The timestamp when the status transition occurred.