org.apache.flink.client.program

类 StreamContextEnvironment

java.lang.Object

org.apache.flink.streaming.api.environment.StreamExecutionEnvironment

org.apache.flink.client.program.StreamContextEnvironment

@PublicEvolving
public class StreamContextEnvironment
extends org.apache.flink.streaming.api.environment.StreamExecutionEnvironment

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

字段概要

从类继承的字段 org.apache.flink.streaming.api.environment.StreamExecutionEnvironment

cacheFile, DEFAULT_JOB_NAME, isChainingEnabled, transformations

构造器概要

构造器

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

方法概要

限定符和类型	方法和说明
org.apache.flink.api.common.JobExecutionResult	execute(org.apache.flink.streaming.api.graph.StreamGraph streamGraph)
org.apache.flink.core.execution.JobClient	executeAsync(org.apache.flink.streaming.api.graph.StreamGraph streamGraph)
static void	setAsContext(org.apache.flink.core.execution.PipelineExecutorServiceLoader executorServiceLoader, org.apache.flink.configuration.Configuration configuration, ClassLoader userCodeClassLoader, boolean enforceSingleJobExecution, boolean suppressSysout)
static void	unsetAsContext()

从类继承的方法 org.apache.flink.streaming.api.environment.StreamExecutionEnvironment

addDefaultKryoSerializer, addDefaultKryoSerializer, addOperator, addSource, addSource, addSource, addSource, clean, clearJobListeners, configure, createInput, createInput, createLocalEnvironment, createLocalEnvironment, createLocalEnvironment, createLocalEnvironmentWithWebUI, createRemoteEnvironment, createRemoteEnvironment, createRemoteEnvironment, disableOperatorChaining, enableCheckpointing, enableCheckpointing, enableCheckpointing, enableCheckpointing, execute, execute, executeAsync, executeAsync, fromCollection, fromCollection, fromCollection, fromCollection, fromElements, fromElements, fromParallelCollection, fromParallelCollection, fromSource, fromSource, generateSequence, getBufferTimeout, getCachedFiles, getCheckpointConfig, getCheckpointingMode, getCheckpointInterval, getConfig, getConfiguration, getDefaultLocalParallelism, getExecutionEnvironment, getExecutionPlan, getJobListeners, getMaxParallelism, getNumberOfExecutionRetries, getParallelism, getRestartStrategy, getStateBackend, getStreamGraph, getStreamGraph, getStreamGraph, getStreamTimeCharacteristic, getUserClassloader, initializeContextEnvironment, isChainingEnabled, isForceCheckpointing, readFile, readFile, readFile, readFile, readFileStream, readTextFile, readTextFile, registerCachedFile, registerCachedFile, registerJobListener, registerType, registerTypeWithKryoSerializer, registerTypeWithKryoSerializer, resetContextEnvironment, setBufferTimeout, setDefaultLocalParallelism, setMaxParallelism, setNumberOfExecutionRetries, setParallelism, setRestartStrategy, setStateBackend, setStateBackend, setStreamTimeCharacteristic, socketTextStream, socketTextStream, socketTextStream, socketTextStream, socketTextStream

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

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

构造器详细资料

StreamContextEnvironment

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

方法详细资料

execute

public org.apache.flink.api.common.JobExecutionResult execute(org.apache.flink.streaming.api.graph.StreamGraph streamGraph)
                                                       throws Exception

覆盖:

execute 在类中 org.apache.flink.streaming.api.environment.StreamExecutionEnvironment

抛出:

Exception

executeAsync

public org.apache.flink.core.execution.JobClient executeAsync(org.apache.flink.streaming.api.graph.StreamGraph streamGraph)
                                                       throws Exception

覆盖:

executeAsync 在类中 org.apache.flink.streaming.api.environment.StreamExecutionEnvironment

抛出:

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()