org.apache.flink.datastream.impl

类 ExecutionContextEnvironment

java.lang.Object

org.apache.flink.datastream.impl.ExecutionEnvironmentImpl

org.apache.flink.datastream.impl.ExecutionContextEnvironment

所有已实现的接口:

org.apache.flink.datastream.api.ExecutionEnvironment

public class ExecutionContextEnvironment
extends ExecutionEnvironmentImpl

Special ExecutionEnvironment that will be used in cases where the CLI client or testing utilities create a ExecutionEnvironment that should be used when ExecutionEnvironment.getInstance() ()} is called.

构造器概要

构造器

构造器和说明
ExecutionContextEnvironment(org.apache.flink.core.execution.PipelineExecutorServiceLoader executorServiceLoader, org.apache.flink.configuration.Configuration configuration, ClassLoader userCodeClassLoader)

方法概要

限定符和类型	方法和说明
static void	setAsContext(org.apache.flink.core.execution.PipelineExecutorServiceLoader executorServiceLoader, org.apache.flink.configuration.Configuration clusterConfiguration, ClassLoader userCodeClassLoader)
static void	unsetAsContext()

从类继承的方法 org.apache.flink.datastream.impl.ExecutionEnvironmentImpl

addOperator, execute, fromSource, getCheckpointCfg, getConfiguration, getExecutionConfig, getExecutionMode, getParallelism, getStreamGraph, getTransformations, initializeContextEnvironment, newInstance, resetContextEnvironment, setExecutionMode, setParallelism

从类继承的方法 java.lang.Object

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

从接口继承的方法 org.apache.flink.datastream.api.ExecutionEnvironment

getInstance

构造器详细资料

ExecutionContextEnvironment

public ExecutionContextEnvironment(org.apache.flink.core.execution.PipelineExecutorServiceLoader executorServiceLoader,
                                   org.apache.flink.configuration.Configuration configuration,
                                   ClassLoader userCodeClassLoader)

方法详细资料

setAsContext

public static void setAsContext(org.apache.flink.core.execution.PipelineExecutorServiceLoader executorServiceLoader,
                                org.apache.flink.configuration.Configuration clusterConfiguration,
                                ClassLoader userCodeClassLoader)

unsetAsContext

public static void unsetAsContext()