Package org.apache.flink.core.execution

Class JobStatusChangedListenerUtils

java.lang.Object

org.apache.flink.core.execution.JobStatusChangedListenerUtils

@Internal
public final class JobStatusChangedListenerUtils
extends Object

Util class for JobStatusChangedListener.

Constructor Summary

Constructors

Constructor	Description
JobStatusChangedListenerUtils()

Method Summary

Modifier and Type	Method	Description
static List<JobStatusChangedListener>	createJobStatusChangedListeners(ClassLoader userClassLoader, Configuration configuration, Executor ioExecutor)	Create job status changed listeners from configuration for job.

Methods inherited from class java.lang.Object

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

Constructor Detail

JobStatusChangedListenerUtils

public JobStatusChangedListenerUtils()

Method Detail

createJobStatusChangedListeners

public static List<JobStatusChangedListener> createJobStatusChangedListeners(ClassLoader userClassLoader,
                                                                             Configuration configuration,
                                                                             Executor ioExecutor)

Create job status changed listeners from configuration for job.

Parameters:

configuration - The job configuration.

Returns:

the job status changed listeners.