Package org.apache.flink.client.program

Class OptimizerPlanEnvironment

  • public class OptimizerPlanEnvironment
extends org.apache.flink.api.java.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 Description
      OptimizerPlanEnvironment​(org.apache.flink.configuration.Configuration configuration, ClassLoader userClassloader, int parallelism)  

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      org.apache.flink.core.execution.JobClient executeAsync​(String jobName)  
      org.apache.flink.api.dag.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

    • Constructor Detail

      • OptimizerPlanEnvironment

        public OptimizerPlanEnvironment​(org.apache.flink.configuration.Configuration configuration,
                                ClassLoader userClassloader,
                                int parallelism)

    • Method Detail

      • getPipeline

        public org.apache.flink.api.dag.Pipeline getPipeline()

      • executeAsync

        public org.apache.flink.core.execution.JobClient executeAsync​(String jobName)
        Overrides:
        executeAsync in class org.apache.flink.api.java.ExecutionEnvironment

      • setAsContext

        public void setAsContext()

      • unsetAsContext

        public void unsetAsContext()