public class StreamExecutionEnvironment$ extends Object
Modifier and Type | Field and Description |
---|---|
static StreamExecutionEnvironment$ |
MODULE$
Static reference to the singleton instance of this Scala object.
|
Constructor and Description |
---|
StreamExecutionEnvironment$() |
Modifier and Type | Method and Description |
---|---|
StreamExecutionEnvironment |
createLocalEnvironment(int parallelism)
Creates a local execution environment.
|
StreamExecutionEnvironment |
createLocalEnvironmentWithWebUI(Configuration config)
Creates a
StreamExecutionEnvironment for local program execution that also starts the
web monitoring UI. |
StreamExecutionEnvironment |
createRemoteEnvironment(String host,
int port,
int parallelism,
scala.collection.Seq<String> jarFiles)
Creates a remote execution environment.
|
StreamExecutionEnvironment |
createRemoteEnvironment(String host,
int port,
scala.collection.Seq<String> jarFiles)
Creates a remote execution environment.
|
int |
getDefaultLocalParallelism()
Gets the default parallelism that will be used for the local execution environment created by
createLocalEnvironment() . |
StreamExecutionEnvironment |
getExecutionEnvironment()
Creates an execution environment that represents the context in which the program is
currently executed.
|
void |
setDefaultLocalParallelism(int parallelism)
Sets the default parallelism that will be used for the local execution
environment created by
createLocalEnvironment() . |
public static final StreamExecutionEnvironment$ MODULE$
public void setDefaultLocalParallelism(int parallelism)
createLocalEnvironment()
.
parallelism
- The default parallelism to use for local execution.public int getDefaultLocalParallelism()
createLocalEnvironment()
.public StreamExecutionEnvironment getExecutionEnvironment()
public StreamExecutionEnvironment createLocalEnvironment(int parallelism)
This method sets the environment's default parallelism to given parameter, which
defaults to the value set via setDefaultLocalParallelism(Int)
.
parallelism
- (undocumented)public StreamExecutionEnvironment createLocalEnvironmentWithWebUI(Configuration config)
StreamExecutionEnvironment
for local program execution that also starts the
web monitoring UI.
The local execution environment will run the program in a multi-threaded fashion in the same JVM as the environment was created in. It will use the parallelism specified in the parameter.
If the configuration key 'jobmanager.web.port' was set in the configuration, that particular port will be used for the web UI. Otherwise, the default port (8081) will be used.
config
- optional config for the local executionpublic StreamExecutionEnvironment createRemoteEnvironment(String host, int port, scala.collection.Seq<String> jarFiles)
StreamExecutionEnvironment.setParallelism()
.
host
- The host name or address of the master (JobManager),
where the program should be executed.port
- The port of the master (JobManager), where the program should be executed.jarFiles
- The JAR files with code that needs to be shipped to the cluster. If the
program uses
user-defined functions, user-defined input formats, or any libraries,
those must be
provided in the JAR files.public StreamExecutionEnvironment createRemoteEnvironment(String host, int port, int parallelism, scala.collection.Seq<String> jarFiles)
host
- The host name or address of the master (JobManager),
where the program should be executed.port
- The port of the master (JobManager), where the program should be executed.parallelism
- The parallelism to use during the execution.jarFiles
- The JAR files with code that needs to be shipped to the cluster. If the
program uses
user-defined functions, user-defined input formats, or any libraries,
those must be
provided in the JAR files.Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.