Package org.apache.flink.runtime.executiongraph

Interface JobStatusListener

All Known Implementing Classes:

CheckpointCoordinatorDeActivator, JobStatusMetrics, JobStatusStore

public interface JobStatusListener

Interface for observers that monitor the status of a job.

Method Summary

Modifier and Type	Method	Description
static JobStatusListener	combine(JobStatusListener... jobStatusListeners)
void	jobStatusChanges(org.apache.flink.api.common.JobID jobId, org.apache.flink.api.common.JobStatus newJobStatus, long timestamp)	This method is called whenever the status of the job changes.

Method Detail

jobStatusChanges

void jobStatusChanges(org.apache.flink.api.common.JobID jobId,
                      org.apache.flink.api.common.JobStatus newJobStatus,
                      long timestamp)

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

Parameters:

jobId - The ID of the job.

newJobStatus - The status the job switched to.

timestamp - The timestamp when the status transition occurred.

combine

static JobStatusListener combine(JobStatusListener... jobStatusListeners)