org.apache.flink.client.program

Class JobWithJars

java.lang.Object

org.apache.flink.client.program.JobWithJars

public class JobWithJars
extends Object

A JobWithJars is a Flink dataflow plan, together with a bunch of JAR files that contain the classes of the functions and libraries necessary for the execution.

Constructor Summary

Constructors

Constructor and Description
JobWithJars(Plan plan, List<URL> jarFiles, List<URL> classpaths)
JobWithJars(Plan plan, URL jarFile)

Method Summary

Modifier and Type	Method and Description
static ClassLoader	buildUserCodeClassLoader(List<URL> jars, List<URL> classpaths, ClassLoader parent)
static void	checkJarFile(URL jar)
List<URL>	getClasspaths() Returns list of classpaths that need to be submitted with the plan.
List<URL>	getJarFiles() Returns list of jar files that need to be submitted with the plan.
Plan	getPlan() Returns the plan
ClassLoader	getUserCodeClassLoader() Gets the ClassLoader that must be used to load user code classes.

Methods inherited from class java.lang.Object

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

Constructor Detail

JobWithJars

public JobWithJars(Plan plan,
                   List<URL> jarFiles,
                   List<URL> classpaths)
            throws IOException

Throws:

IOException

JobWithJars

public JobWithJars(Plan plan,
                   URL jarFile)
            throws IOException

Throws:

IOException

Method Detail

getPlan

public Plan getPlan()

Returns the plan

getJarFiles

public List<URL> getJarFiles()

Returns list of jar files that need to be submitted with the plan.

getClasspaths

public List<URL> getClasspaths()

Returns list of classpaths that need to be submitted with the plan.

getUserCodeClassLoader

public ClassLoader getUserCodeClassLoader()

Gets the ClassLoader that must be used to load user code classes.

Returns:

The user code ClassLoader.

checkJarFile

public static void checkJarFile(URL jar)
                         throws IOException

Throws:

IOException

buildUserCodeClassLoader

public static ClassLoader buildUserCodeClassLoader(List<URL> jars,
                                                   List<URL> classpaths,
                                                   ClassLoader parent)