org.apache.flink.client.program

Class DetachedEnvironment

java.lang.Object

org.apache.flink.api.java.ExecutionEnvironment

org.apache.flink.client.program.ContextEnvironment

org.apache.flink.client.program.DetachedEnvironment

public class DetachedEnvironment
extends ContextEnvironment

Execution Environment for remote execution with the Client in detached mode.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	DetachedEnvironment.DetachedJobExecutionResult The JobExecutionResult returned by a DetachedEnvironment.

Field Summary

Fields inherited from class org.apache.flink.client.program.ContextEnvironment

classpathsToAttach, client, jarFilesToAttach, savepointSettings, userCodeClassLoader

Fields inherited from class org.apache.flink.api.java.ExecutionEnvironment

jobID, lastJobExecutionResult, sessionTimeout

Constructor Summary

Constructors

Constructor and Description
DetachedEnvironment(ClusterClient remoteConnection, List<URL> jarFiles, List<URL> classpaths, ClassLoader userCodeClassLoader, SavepointRestoreSettings savepointSettings)

Method Summary

Modifier and Type	Method and Description
JobExecutionResult	execute(String jobName) Triggers the program execution.
void	setDetachedPlan(FlinkPlan plan)

Methods inherited from class org.apache.flink.client.program.ContextEnvironment

getClasspaths, getClient, getExecutionPlan, getJars, getSavepointRestoreSettings, getUserCodeClassLoader, startNewSession, toString

Methods inherited from class org.apache.flink.api.java.ExecutionEnvironment

addDefaultKryoSerializer, addDefaultKryoSerializer, areExplicitEnvironmentsAllowed, createCollectionsEnvironment, createInput, createInput, createLocalEnvironment, createLocalEnvironment, createLocalEnvironment, createLocalEnvironmentWithWebUI, createProgramPlan, createProgramPlan, createProgramPlan, createRemoteEnvironment, createRemoteEnvironment, createRemoteEnvironment, execute, fromCollection, fromCollection, fromCollection, fromCollection, fromElements, fromElements, fromParallelCollection, fromParallelCollection, generateSequence, getConfig, getDefaultLocalParallelism, getExecutionEnvironment, getId, getIdString, getLastJobExecutionResult, getNumberOfExecutionRetries, getParallelism, getRestartStrategy, getSessionTimeout, initializeContextEnvironment, readCsvFile, readFile, readFileOfPrimitives, readFileOfPrimitives, readTextFile, readTextFile, readTextFileWithValue, readTextFileWithValue, registerCachedFile, registerCachedFile, registerCachedFilesWithPlan, registerType, registerTypeWithKryoSerializer, registerTypeWithKryoSerializer, resetContextEnvironment, setDefaultLocalParallelism, setNumberOfExecutionRetries, setParallelism, setRestartStrategy, setSessionTimeout

Methods inherited from class java.lang.Object

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

Constructor Detail

DetachedEnvironment

public DetachedEnvironment(ClusterClient remoteConnection,
                           List<URL> jarFiles,
                           List<URL> classpaths,
                           ClassLoader userCodeClassLoader,
                           SavepointRestoreSettings savepointSettings)

Method Detail

execute

public JobExecutionResult execute(String jobName)
                           throws Exception

Description copied from class: ExecutionEnvironment

Triggers the program execution. The environment will execute all parts of the program that have resulted in a "sink" operation. Sink operations are for example printing results (DataSet.print(), writing results (e.g. DataSet.writeAsText(String), DataSet.write(org.apache.flink.api.common.io.FileOutputFormat, String), or other generic data sinks created with DataSet.output(org.apache.flink.api.common.io.OutputFormat).

The program execution will be logged and displayed with the given job name.

Overrides:

execute in class ContextEnvironment

Returns:

The result of the job execution, containing elapsed time and accumulators.

Throws:

Exception - Thrown, if the program executions fails.

setDetachedPlan

public void setDetachedPlan(FlinkPlan plan)