public class OptimizerPlanEnvironment extends ExecutionEnvironment
ExecutionEnvironment
that never executes a job but only extracts the Pipeline
.Modifier and Type | Class and Description |
---|---|
static class |
OptimizerPlanEnvironment.ProgramAbortException
A special exception used to abort programs when the caller is only interested in the
program plan, rather than in the full execution.
|
lastJobExecutionResult, LOG
Constructor and Description |
---|
OptimizerPlanEnvironment(Configuration configuration,
ClassLoader userClassloader) |
Modifier and Type | Method and Description |
---|---|
JobClient |
executeAsync(String jobName)
Triggers the program execution asynchronously.
|
Pipeline |
getPipeline(PackagedProgram prog,
boolean suppressOutput)
Retrieves the JobGraph from a PackagedProgram.
|
void |
setPipeline(Pipeline pipeline) |
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, registerCachedFilesWithPlan, registerJobListener, registerType, registerTypeWithKryoSerializer, registerTypeWithKryoSerializer, resetContextEnvironment, setDefaultLocalParallelism, setNumberOfExecutionRetries, setParallelism, setRestartStrategy
public OptimizerPlanEnvironment(Configuration configuration, ClassLoader userClassloader)
public JobClient executeAsync(String jobName) throws Exception
ExecutionEnvironment
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.
executeAsync
in class ExecutionEnvironment
JobClient
that can be used to communicate with the submitted job, completed on submission succeeded.Exception
- Thrown, if the program submission fails.public Pipeline getPipeline(PackagedProgram prog, boolean suppressOutput) throws ProgramInvocationException
prog
- The program to runsuppressOutput
- Whether to suppress stdout/stderr. Output is always printed on errors.ProgramInvocationException
- in case of errors.public void setPipeline(Pipeline pipeline)
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.