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.runtime.jobgraph.JobGraph	getJobGraph(org.apache.flink.api.dag.Pipeline pipeline, org.apache.flink.configuration.Configuration configuration, ClassLoader userClassloader)	Creates the JobGraph corresponding to the provided Pipeline.

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

getJobGraph

public static org.apache.flink.runtime.jobgraph.JobGraph getJobGraph(@Nonnull
                                                                     org.apache.flink.api.dag.Pipeline pipeline,
                                                                     @Nonnull
                                                                     org.apache.flink.configuration.Configuration configuration,
                                                                     @Nonnull
                                                                     ClassLoader userClassloader)
                                                              throws MalformedURLException

Creates the JobGraph corresponding to the provided Pipeline.

Parameters:

pipeline - the pipeline whose job graph we are computing.

configuration - the configuration with the necessary information such as jars and classpaths to be included, the parallelism of the job and potential savepoint settings used to bootstrap its state.

userClassloader - the classloader which can load user classes.

Returns:

the corresponding JobGraph.

Throws:

MalformedURLException