public class ExecutionEnvironment$ extends Object
Modifier and Type | Field and Description |
---|---|
static ExecutionEnvironment$ |
MODULE$
Static reference to the singleton instance of this Scala object.
|
Constructor and Description |
---|
ExecutionEnvironment$() |
Modifier and Type | Method and Description |
---|---|
ExecutionEnvironment |
createCollectionsEnvironment()
Creates an execution environment that uses Java Collections underneath.
|
ExecutionEnvironment |
createLocalEnvironment(Configuration customConfiguration)
Creates a local execution environment.
|
ExecutionEnvironment |
createLocalEnvironment(int parallelism)
Creates a local execution environment.
|
ExecutionEnvironment |
createLocalEnvironmentWithWebUI(Configuration config)
Creates a
ExecutionEnvironment for local program execution that also starts the
web monitoring UI. |
ExecutionEnvironment |
createRemoteEnvironment(String host,
int port,
Configuration clientConfiguration,
scala.collection.Seq<String> jarFiles)
Creates a remote execution environment.
|
ExecutionEnvironment |
createRemoteEnvironment(String host,
int port,
int parallelism,
scala.collection.Seq<String> jarFiles)
Creates a remote execution environment.
|
ExecutionEnvironment |
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() . |
ExecutionEnvironment |
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 ExecutionEnvironment$ MODULE$
public void setDefaultLocalParallelism(int parallelism)
createLocalEnvironment()
.
parallelism
- The default parallelism to use for local execution.public int getDefaultLocalParallelism()
createLocalEnvironment()
.public ExecutionEnvironment getExecutionEnvironment()
public ExecutionEnvironment createLocalEnvironment(int parallelism)
This method sets the environment's default parallelism to given parameter, which
defaults to the value set via setDefaultLocalParallelism(Int)
.
public ExecutionEnvironment createLocalEnvironment(Configuration customConfiguration)
public ExecutionEnvironment createLocalEnvironmentWithWebUI(Configuration config)
ExecutionEnvironment
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 ExecutionEnvironment createCollectionsEnvironment()
public ExecutionEnvironment createRemoteEnvironment(String host, int port, scala.collection.Seq<String> jarFiles)
ExecutionEnvironment.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 ExecutionEnvironment 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.public ExecutionEnvironment createRemoteEnvironment(String host, int port, Configuration clientConfiguration, scala.collection.Seq<String> jarFiles)
ExecutionEnvironment.setParallelism
.
ClusterClient configuration has to be done in the remotely running Flink instance.
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.clientConfiguration
- Pass a custom configuration to the Client.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–2017 The Apache Software Foundation. All rights reserved.