org.apache.flink.client.deployment.executors

Class ExecutorUtils

java.lang.Object

org.apache.flink.client.deployment.executors.ExecutorUtils

public class ExecutorUtils
extends Object

Utility class with method related to job execution.

Constructor Summary

Constructors

Constructor and Description
ExecutorUtils()

Method Summary

Modifier and Type	Method and Description
static JobGraph	getJobGraph(Pipeline pipeline, Configuration configuration) 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

ExecutorUtils

public ExecutorUtils()

Method Detail

getJobGraph

public static JobGraph getJobGraph(@Nonnull
                                   Pipeline pipeline,
                                   @Nonnull
                                   Configuration configuration)

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.

Returns:

the corresponding JobGraph.