@Deprecated @Public public class LocalEnvironment extends ExecutionEnvironment
ExecutionEnvironment
that runs the program locally, multi-threaded, in the JVM where
the environment is instantiated.
When this environment is instantiated, it uses a default parallelism of 1
. The default
parallelism can be set via ExecutionEnvironment.setParallelism(int)
.
Local environments can also be instantiated through ExecutionEnvironment.createLocalEnvironment()
and ExecutionEnvironment.createLocalEnvironment(int)
. The former version will pick a default
parallelism equal to the number of hardware contexts in the local machine.
lastJobExecutionResult, LOG
Constructor and Description |
---|
LocalEnvironment()
Deprecated.
Creates a new local environment.
|
LocalEnvironment(Configuration config)
Deprecated.
Creates a new local environment that configures its local executor with the given
configuration.
|
Modifier and Type | Method and Description |
---|---|
String |
toString()
Deprecated.
|
addDefaultKryoSerializer, addDefaultKryoSerializer, areExplicitEnvironmentsAllowed, clearJobListeners, configure, createCollectionsEnvironment, createInput, createInput, createLocalEnvironment, createLocalEnvironment, createLocalEnvironment, createLocalEnvironmentWithWebUI, createProgramPlan, createProgramPlan, createProgramPlan, createRemoteEnvironment, createRemoteEnvironment, createRemoteEnvironment, execute, execute, executeAsync, executeAsync, fromCollection, fromCollection, fromCollection, fromCollection, fromElements, fromElements, fromParallelCollection, fromParallelCollection, generateSequence, getConfig, getConfiguration, getDefaultLocalParallelism, getExecutionEnvironment, getExecutionPlan, getExecutorServiceLoader, getJobListeners, getLastJobExecutionResult, getNumberOfExecutionRetries, getParallelism, getRestartStrategy, getUserCodeClassLoader, initializeContextEnvironment, readCsvFile, readFile, readFileOfPrimitives, readFileOfPrimitives, readTextFile, readTextFile, readTextFileWithValue, readTextFileWithValue, registerCachedFile, registerCachedFile, registerJobListener, registerType, registerTypeWithKryoSerializer, registerTypeWithKryoSerializer, resetContextEnvironment, setDefaultLocalParallelism, setNumberOfExecutionRetries, setParallelism, setRestartStrategy
public LocalEnvironment()
public LocalEnvironment(Configuration config)
config
- The configuration used to configure the local executor.Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.