org.apache.flink.client.program

Class PackagedProgramUtils

java.lang.Object

org.apache.flink.client.program.PackagedProgramUtils

public class PackagedProgramUtils
extends Object

Utility class for PackagedProgram related operations.

Method Summary

Modifier and Type	Method and Description
static JobGraph	createJobGraph(PackagedProgram packagedProgram, Configuration configuration, int defaultParallelism) Creates a JobGraph from the given PackagedProgram.

Methods inherited from class java.lang.Object

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

Method Detail

createJobGraph

public static JobGraph createJobGraph(PackagedProgram packagedProgram,
                                      Configuration configuration,
                                      int defaultParallelism)
                               throws ProgramInvocationException

Creates a JobGraph from the given PackagedProgram.

Parameters:

packagedProgram - to extract the JobGraph from

configuration - to use for the optimizer and job graph generator

defaultParallelism - for the JobGraph

Returns:

JobGraph extracted from the PackagedProgram

Throws:

ProgramInvocationException - if the JobGraph generation failed