@Public public class LocalStreamEnvironment extends StreamExecutionEnvironment
When this environment is instantiated, it uses a default parallelism of 1
. The default
parallelism can be set via StreamExecutionEnvironment.setParallelism(int)
.
Local environments can also be instantiated through StreamExecutionEnvironment.createLocalEnvironment()
and StreamExecutionEnvironment.createLocalEnvironment(int)
. The former version will pick a
default parallelism equal to the number of hardware contexts in the local machine.
DEFAULT_JOB_NAME, isChainingEnabled, transformations
Constructor and Description |
---|
LocalStreamEnvironment()
Creates a new local stream environment that uses the default configuration.
|
LocalStreamEnvironment(Configuration config)
Creates a new local stream environment that configures its local executor with the given configuration.
|
Modifier and Type | Method and Description |
---|---|
JobExecutionResult |
execute(String jobName)
Executes the JobGraph of the on a mini cluster of CLusterUtil with a user
specified name.
|
addDefaultKryoSerializer, addDefaultKryoSerializer, addOperator, addSource, addSource, addSource, addSource, clean, createInput, createInput, createLocalEnvironment, createLocalEnvironment, createLocalEnvironment, createRemoteEnvironment, createRemoteEnvironment, createRemoteEnvironment, disableOperatorChaining, enableCheckpointing, enableCheckpointing, enableCheckpointing, enableCheckpointing, execute, fromCollection, fromCollection, fromCollection, fromCollection, fromElements, fromElements, fromParallelCollection, fromParallelCollection, generateSequence, getBufferTimeout, getCheckpointConfig, getCheckpointingMode, getCheckpointInterval, getConfig, getExecutionEnvironment, getExecutionPlan, getNumberOfExecutionRetries, getParallelism, getRestartStrategy, getStateBackend, getStreamGraph, getStreamTimeCharacteristic, initializeContextEnvironment, isChainingEnabled, isForceCheckpointing, readFile, readFile, readFile, readFileStream, readTextFile, readTextFile, registerType, registerTypeWithKryoSerializer, registerTypeWithKryoSerializer, resetContextEnvironment, setBufferTimeout, setDefaultLocalParallelism, setNumberOfExecutionRetries, setParallelism, setRestartStrategy, setStateBackend, setStreamTimeCharacteristic, socketTextStream, socketTextStream, socketTextStream, socketTextStream, socketTextStream
public LocalStreamEnvironment()
public LocalStreamEnvironment(Configuration config)
config
- The configuration used to configure the local executor.public JobExecutionResult execute(String jobName) throws Exception
execute
in class StreamExecutionEnvironment
jobName
- name of the jobException
- which occurs during job execution.Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.