Package org.apache.flink.client.deployment.executors

Class PipelineExecutorUtils

java.lang.Object

org.apache.flink.client.deployment.executors.PipelineExecutorUtils

public class PipelineExecutorUtils
extends Object

Utility class with method related to job execution.

Constructor Summary

Constructors

Constructor	Description
PipelineExecutorUtils()

Method Summary

Modifier and Type	Method	Description
static org.apache.flink.streaming.api.graph.StreamGraph	getStreamGraph(org.apache.flink.api.dag.Pipeline pipeline, org.apache.flink.configuration.Configuration configuration)
static void	notifyJobStatusListeners(org.apache.flink.api.dag.Pipeline pipeline, org.apache.flink.streaming.api.graph.ExecutionPlan executionPlan, List<org.apache.flink.core.execution.JobStatusChangedListener> listeners)	Notify the DefaultJobCreatedEvent to job status changed listeners.

Methods inherited from class java.lang.Object

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

Constructor Detail

PipelineExecutorUtils

public PipelineExecutorUtils()

Method Detail

notifyJobStatusListeners

public static void notifyJobStatusListeners(@Nonnull
                                            org.apache.flink.api.dag.Pipeline pipeline,
                                            @Nonnull
                                            org.apache.flink.streaming.api.graph.ExecutionPlan executionPlan,
                                            List<org.apache.flink.core.execution.JobStatusChangedListener> listeners)

Notify the DefaultJobCreatedEvent to job status changed listeners.

Parameters:

pipeline - the pipeline that contains lineage graph information.

executionPlan - executionPlan that contains job basic info

listeners - the list of job status changed listeners

getStreamGraph

public static org.apache.flink.streaming.api.graph.StreamGraph getStreamGraph(@Nonnull
                                                                              org.apache.flink.api.dag.Pipeline pipeline,
                                                                              @Nonnull
                                                                              org.apache.flink.configuration.Configuration configuration)
                                                                       throws Exception

Throws:

Exception