Package org.apache.flink.core.execution

Class DefaultJobExecutionStatusEvent

java.lang.Object

org.apache.flink.core.execution.DefaultJobExecutionStatusEvent

All Implemented Interfaces:

JobExecutionStatusEvent, JobStatusChangedEvent

@Internal
public class DefaultJobExecutionStatusEvent
extends Object
implements JobExecutionStatusEvent

Default implementation for JobExecutionStatusEvent.

Constructor Summary

Constructors

Constructor	Description
DefaultJobExecutionStatusEvent(JobID jobId, String jobName, JobStatus oldStatus, JobStatus newStatus, Throwable cause)

Method Summary

Modifier and Type	Method	Description
Throwable	exception()	Exception for job.
JobID	jobId()
String	jobName()
JobStatus	newStatus()	New status for job.
JobStatus	oldStatus()	Old status for job.

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultJobExecutionStatusEvent

public DefaultJobExecutionStatusEvent(JobID jobId,
                                      String jobName,
                                      JobStatus oldStatus,
                                      JobStatus newStatus,
                                      @Nullable
                                      Throwable cause)

Method Detail

oldStatus

public JobStatus oldStatus()

Description copied from interface: JobExecutionStatusEvent

Old status for job.

Specified by:

oldStatus in interface JobExecutionStatusEvent

newStatus

public JobStatus newStatus()

Description copied from interface: JobExecutionStatusEvent

New status for job.

Specified by:

newStatus in interface JobExecutionStatusEvent

exception

@Nullable
public Throwable exception()

Description copied from interface: JobExecutionStatusEvent

Exception for job.

Specified by:

exception in interface JobExecutionStatusEvent

jobId

public JobID jobId()

Specified by:

jobId in interface JobStatusChangedEvent

jobName

public String jobName()

Specified by:

jobName in interface JobStatusChangedEvent