org.apache.flink.client.program

Class OptimizerPlanEnvironment

java.lang.Object

org.apache.flink.api.java.ExecutionEnvironment

org.apache.flink.client.program.OptimizerPlanEnvironment

public class OptimizerPlanEnvironment
extends ExecutionEnvironment

An ExecutionEnvironment that never executes a job but only extracts the Pipeline.

Field Summary

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

lastJobExecutionResult, LOG

Constructor Summary

Constructors

Constructor and Description
OptimizerPlanEnvironment(Configuration configuration, ClassLoader userClassloader, int parallelism)

Method Summary

Modifier and Type	Method and Description
JobClient	executeAsync(String jobName) Triggers the program execution asynchronously.
Pipeline	getPipeline()
void	setAsContext()
void	unsetAsContext()

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

addDefaultKryoSerializer, addDefaultKryoSerializer, areExplicitEnvironmentsAllowed, clearJobListeners, configure, createCollectionsEnvironment, createInput, createInput, createLocalEnvironment, createLocalEnvironment, createLocalEnvironment, createLocalEnvironmentWithWebUI, createProgramPlan, createProgramPlan, createProgramPlan, createRemoteEnvironment, createRemoteEnvironment, createRemoteEnvironment, execute, execute, executeAsync, fromCollection, fromCollection, fromCollection, fromCollection, fromElements, fromElements, fromParallelCollection, fromParallelCollection, generateSequence, getConfig, getConfiguration, getDefaultLocalParallelism, getExecutionEnvironment, getExecutionPlan, getExecutorServiceLoader, getJobListeners, getLastJobExecutionResult, getNumberOfExecutionRetries, getParallelism, getRestartStrategy, getUserCodeClassLoader, initializeContextEnvironment, readCsvFile, readFile, readFileOfPrimitives, readFileOfPrimitives, readTextFile, readTextFile, readTextFileWithValue, readTextFileWithValue, registerCachedFile, registerCachedFile, registerJobListener, registerType, registerTypeWithKryoSerializer, registerTypeWithKryoSerializer, resetContextEnvironment, setDefaultLocalParallelism, setNumberOfExecutionRetries, setParallelism, setRestartStrategy

Methods inherited from class java.lang.Object

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

Constructor Detail

OptimizerPlanEnvironment

public OptimizerPlanEnvironment(Configuration configuration,
                                ClassLoader userClassloader,
                                int parallelism)

Method Detail

getPipeline

public Pipeline getPipeline()

executeAsync

public JobClient executeAsync(String jobName)

Description copied from class: ExecutionEnvironment

Triggers the program execution asynchronously. 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:

executeAsync in class ExecutionEnvironment

Returns:

A JobClient that can be used to communicate with the submitted job, completed on submission succeeded.

setAsContext

public void setAsContext()

unsetAsContext

public void unsetAsContext()