org.apache.flink.client.deployment.application

Class FromClasspathEntryClassInformationProvider

java.lang.Object

org.apache.flink.client.deployment.application.FromClasspathEntryClassInformationProvider

All Implemented Interfaces:

EntryClassInformationProvider

public class FromClasspathEntryClassInformationProvider
extends Object
implements EntryClassInformationProvider

FromClasspathEntryClassInformationProvider assumes the passed job class being available on some classpath.

Method Summary

Modifier and Type	Method and Description
static FromClasspathEntryClassInformationProvider	create(String jobClassName, Iterable<URL> classpath) Creates a FromClasspathEntryClassInformationProvider based on the passed job class and classpath.
static FromClasspathEntryClassInformationProvider	createFromClasspath(Iterable<URL> classpath) Creates a FromClasspathEntryClassInformationProvider looking for the entry class providing the main method on the passed classpath.
static FromClasspathEntryClassInformationProvider	createFromSystemClasspath() Creates a FromClasspathEntryClassInformationProvider looking for the entry class providing the main method on the system classpath.
static FromClasspathEntryClassInformationProvider	createWithJobClassAssumingOnSystemClasspath(String jobClassName) Creates a FromClasspathEntryClassInformationProvider assuming that the passed job class is available on the system classpath.
Optional<File>	getJarFile() Always returns an empty Optional because this implementation relies on the JAR archive being available on either the user or the system classpath.
Optional<String>	getJobClassName() Returns the job class name if it could be derived from the specified classpath or was explicitly specified.

Methods inherited from class java.lang.Object

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

Method Detail

create

public static FromClasspathEntryClassInformationProvider create(String jobClassName,
                                                                Iterable<URL> classpath)
                                                         throws IOException,
                                                                FlinkException

Creates a FromClasspathEntryClassInformationProvider based on the passed job class and classpath.

Parameters:

jobClassName - The job's class name.

classpath - The classpath the job class should be part of.

Returns:

The FromClasspathEntryClassInformationProvider instances collecting the necessary information.

Throws:

IOException - If some Jar listed on the classpath wasn't accessible.

FlinkException - If the passed job class is not present on the passed classpath.

createFromClasspath

public static FromClasspathEntryClassInformationProvider createFromClasspath(Iterable<URL> classpath)
                                                                      throws IOException,
                                                                             FlinkException

Creates a FromClasspathEntryClassInformationProvider looking for the entry class providing the main method on the passed classpath.

Parameters:

classpath - The classpath the job class is expected to be part of.

Returns:

The FromClasspathEntryClassInformationProvider providing the job class found on the passed classpath.

Throws:

IOException - If some Jar listed on the classpath wasn't accessible.

FlinkException - Either no or too many main methods were found on the classpath.

createFromSystemClasspath

public static FromClasspathEntryClassInformationProvider createFromSystemClasspath()
                                                                            throws IOException,
                                                                                   FlinkException

Creates a FromClasspathEntryClassInformationProvider looking for the entry class providing the main method on the system classpath.

Returns:

The FromClasspathEntryClassInformationProvider providing the job class found on the system classpath.

Throws:

IOException - If some Jar listed on the system classpath wasn't accessible.

FlinkException - Either no or too many main methods were found on the system classpath.

createWithJobClassAssumingOnSystemClasspath

public static FromClasspathEntryClassInformationProvider createWithJobClassAssumingOnSystemClasspath(String jobClassName)

Creates a FromClasspathEntryClassInformationProvider assuming that the passed job class is available on the system classpath.

Parameters:

jobClassName - The job class name working as the entry point.

Returns:

The FromClasspathEntryClassInformationProvider providing the job class found.

getJarFile

public Optional<File> getJarFile()

Always returns an empty Optional because this implementation relies on the JAR archive being available on either the user or the system classpath.

Specified by:

getJarFile in interface EntryClassInformationProvider

Returns:

An empty Optional.

getJobClassName

public Optional<String> getJobClassName()

Returns the job class name if it could be derived from the specified classpath or was explicitly specified.

Specified by:

getJobClassName in interface EntryClassInformationProvider

Returns:

The job class name or an empty Optional if none was specified and it couldn't be derived from the classpath.