org.apache.flink.runtime.entrypoint.component

Class FileJobGraphRetriever

java.lang.Object

org.apache.flink.runtime.entrypoint.component.AbstractUserClassPathJobGraphRetriever

org.apache.flink.runtime.entrypoint.component.FileJobGraphRetriever

All Implemented Interfaces:

JobGraphRetriever

public class FileJobGraphRetriever
extends AbstractUserClassPathJobGraphRetriever

JobGraphRetriever implementation which retrieves the JobGraph from a file on disk.

Field Summary

Fields

Modifier and Type	Field and Description
static ConfigOption<String>	JOB_GRAPH_FILE_PATH

Constructor Summary

Constructors

Constructor and Description
FileJobGraphRetriever(String jobGraphFile, File usrLibDir)

Method Summary

Modifier and Type	Method and Description
static FileJobGraphRetriever	createFrom(Configuration configuration, File usrLibDir)
JobGraph	retrieveJobGraph(Configuration configuration) Retrieve the JobGraph.

Methods inherited from class org.apache.flink.runtime.entrypoint.component.AbstractUserClassPathJobGraphRetriever

getUserClassPaths

Methods inherited from class java.lang.Object

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

Field Detail

JOB_GRAPH_FILE_PATH

public static final ConfigOption<String> JOB_GRAPH_FILE_PATH

Constructor Detail

FileJobGraphRetriever

public FileJobGraphRetriever(@Nonnull
                             String jobGraphFile,
                             @Nullable
                             File usrLibDir)
                      throws IOException

Throws:

IOException

Method Detail

retrieveJobGraph

public JobGraph retrieveJobGraph(Configuration configuration)
                          throws FlinkException

Description copied from interface: JobGraphRetriever

Retrieve the JobGraph.

Parameters:

configuration - cluster configuration

Returns:

the retrieved JobGraph.

Throws:

FlinkException - if the JobGraph could not be retrieved

createFrom

public static FileJobGraphRetriever createFrom(Configuration configuration,
                                               @Nullable
                                               File usrLibDir)
                                        throws IOException

Throws:

IOException