@PublicEvolving
public class StreamContextEnvironment
extends org.apache.flink.streaming.api.environment.StreamExecutionEnvironment
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.| 构造器和说明 |
|---|
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() |
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, socketTextStreampublic StreamContextEnvironment(org.apache.flink.core.execution.PipelineExecutorServiceLoader executorServiceLoader,
org.apache.flink.configuration.Configuration configuration,
ClassLoader userCodeClassLoader,
boolean enforceSingleJobExecution,
boolean suppressSysout)
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.StreamExecutionEnvironmentExceptionpublic org.apache.flink.core.execution.JobClient executeAsync(org.apache.flink.streaming.api.graph.StreamGraph streamGraph)
throws Exception
executeAsync 在类中 org.apache.flink.streaming.api.environment.StreamExecutionEnvironmentExceptionpublic static void setAsContext(org.apache.flink.core.execution.PipelineExecutorServiceLoader executorServiceLoader,
org.apache.flink.configuration.Configuration configuration,
ClassLoader userCodeClassLoader,
boolean enforceSingleJobExecution,
boolean suppressSysout)
public static void unsetAsContext()
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.