Package 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	Description
static ConfigOption<String>	JOB_GRAPH_FILE_PATH

Constructor Summary

Constructors

Constructor	Description
FileJobGraphRetriever(String jobGraphFile, File usrLibDir)

Method Summary

Modifier and Type	Method	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

@Internal
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