Package org.apache.flink.client.program

Class ContextEnvironment

  • public class ContextEnvironment
extends org.apache.flink.api.java.ExecutionEnvironment
    Execution Environment for remote execution with the Client.

    • Field Summary

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

        lastJobExecutionResult

    • Constructor Summary

      Constructors 
      Constructor Description
      ContextEnvironment​(org.apache.flink.core.execution.PipelineExecutorServiceLoader executorServiceLoader, org.apache.flink.configuration.Configuration configuration, ClassLoader userCodeClassLoader, boolean enforceSingleJobExecution, boolean suppressSysout)  

    • Method Summary

      All Methods Static Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      org.apache.flink.api.common.JobExecutionResult execute​(String jobName)  
      org.apache.flink.core.execution.JobClient executeAsync​(String jobName)  
      static void setAsContext​(org.apache.flink.core.execution.PipelineExecutorServiceLoader executorServiceLoader, org.apache.flink.configuration.Configuration configuration, ClassLoader userCodeClassLoader, boolean enforceSingleJobExecution, boolean suppressSysout)  
      String toString()  
      static 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, 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

      • ContextEnvironment

        public ContextEnvironment​(org.apache.flink.core.execution.PipelineExecutorServiceLoader executorServiceLoader,
                          org.apache.flink.configuration.Configuration configuration,
                          ClassLoader userCodeClassLoader,
                          boolean enforceSingleJobExecution,
                          boolean suppressSysout)

    • Method Detail

      • execute

        public org.apache.flink.api.common.JobExecutionResult execute​(String jobName)
                                                       throws Exception
        Overrides:
        execute in class org.apache.flink.api.java.ExecutionEnvironment
        Throws:
        Exception

      • executeAsync

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

      • setAsContext

        public static void setAsContext​(org.apache.flink.core.execution.PipelineExecutorServiceLoader executorServiceLoader,
                                org.apache.flink.configuration.Configuration configuration,
                                ClassLoader userCodeClassLoader,
                                boolean enforceSingleJobExecution,
                                boolean suppressSysout)

      • unsetAsContext

        public static void unsetAsContext()