@PublicEvolving public class StreamContextEnvironment extends 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.cacheFile, DEFAULT_JOB_NAME, isChainingEnabled, transformations
Modifier and Type | Method and Description |
---|---|
JobExecutionResult |
execute(StreamGraph streamGraph)
Triggers the program execution.
|
JobClient |
executeAsync(StreamGraph streamGraph)
Triggers the program execution asynchronously.
|
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, generateSequence, getBufferTimeout, getCachedFiles, getCheckpointConfig, getCheckpointingMode, getCheckpointInterval, getConfig, getConfiguration, getDefaultLocalParallelism, getExecutionEnvironment, getExecutionPlan, getJobListeners, getMaxParallelism, getNumberOfExecutionRetries, getParallelism, getRestartStrategy, getStateBackend, getStreamGraph, getStreamGraph, getStreamGraph, getStreamTimeCharacteristic, 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
public JobExecutionResult execute(StreamGraph streamGraph) throws Exception
StreamExecutionEnvironment
execute
in class StreamExecutionEnvironment
streamGraph
- the stream graph representing the transformationsException
- which occurs during job execution.public JobClient executeAsync(StreamGraph streamGraph) throws Exception
StreamExecutionEnvironment
executeAsync
in class StreamExecutionEnvironment
streamGraph
- the stream graph representing the transformationsJobClient
that can be used to communicate with the submitted job, completed on submission succeeded.Exception
- which occurs during job execution.Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.