object ExecutionEnvironment
- Annotations
- @deprecated @Public()
- Deprecated
(Since version 1.17.0)
- Alphabetic
- By Inheritance
- ExecutionEnvironment
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
Value Members
-
final
def
!=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
##(): Int
- Definition Classes
- AnyRef → Any
-
final
def
==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
-
def
clone(): AnyRef
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @native() @throws( ... )
-
def
createCollectionsEnvironment: ExecutionEnvironment
Creates an execution environment that uses Java Collections underneath.
Creates an execution environment that uses Java Collections underneath. This will execute in a single thread in the current JVM. It is very fast but will fail if the data does not fit into memory. This is useful during implementation and for debugging.
- Annotations
- @PublicEvolving()
-
def
createLocalEnvironment(customConfiguration: Configuration): ExecutionEnvironment
Creates a local execution environment.
Creates a local execution environment. The local execution environment will run the program in a multi-threaded fashion in the same JVM as the environment was created in. This method allows to pass a custom Configuration to the local environment.
-
def
createLocalEnvironment(parallelism: Int = JavaEnv.getDefaultLocalParallelism): ExecutionEnvironment
Creates a local execution environment.
Creates a local execution environment. The local execution environment will run the program in a multi-threaded fashion in the same JVM as the environment was created in.
This method sets the environment's default parallelism to given parameter, which defaults to the value set via setDefaultLocalParallelism(Int).
-
def
createLocalEnvironmentWithWebUI(config: Configuration = null): ExecutionEnvironment
Creates a ExecutionEnvironment for local program execution that also starts the web monitoring UI.
Creates a 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 'rest.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 execution
- returns
The created StreamExecutionEnvironment
- Annotations
- @PublicEvolving()
-
def
createRemoteEnvironment(host: String, port: Int, clientConfiguration: Configuration, jarFiles: String*): ExecutionEnvironment
Creates a remote execution environment.
Creates a remote execution environment. The remote environment sends (parts of) the program to a cluster for execution. Note that all file paths used in the program must be accessible from the cluster. The custom configuration file is used to configure Pekko specific configuration parameters for the Client only; Program parallelism can be set via 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.
- returns
A remote environment that executes the program on a cluster.
-
def
createRemoteEnvironment(host: String, port: Int, parallelism: Int, jarFiles: String*): ExecutionEnvironment
Creates a remote execution environment.
Creates a remote execution environment. The remote environment sends (parts of) the program to a cluster for execution. Note that all file paths used in the program must be accessible from the cluster. The execution will use the specified parallelism.
- 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.
-
def
createRemoteEnvironment(host: String, port: Int, jarFiles: String*): ExecutionEnvironment
Creates a remote execution environment.
Creates a remote execution environment. The remote environment sends (parts of) the program to a cluster for execution. Note that all file paths used in the program must be accessible from the cluster. The execution will use the cluster's default parallelism, unless the parallelism is set explicitly via 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.
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
def
finalize(): Unit
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] )
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
def
getDefaultLocalParallelism: Int
Gets the default parallelism that will be used for the local execution environment created by createLocalEnvironment().
Gets the default parallelism that will be used for the local execution environment created by createLocalEnvironment().
- Annotations
- @PublicEvolving()
-
def
getExecutionEnvironment: ExecutionEnvironment
Creates an execution environment that represents the context in which the program is currently executed.
Creates an execution environment that represents the context in which the program is currently executed. If the program is invoked standalone, this method returns a local execution environment. If the program is invoked from within the command line client to be submitted to a cluster, this method returns the execution environment of this cluster.
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
-
final
def
ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
final
def
notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
-
def
setDefaultLocalParallelism(parallelism: Int): Unit
Sets the default parallelism that will be used for the local execution environment created by createLocalEnvironment().
Sets the default parallelism that will be used for the local execution environment created by createLocalEnvironment().
- parallelism
The default parallelism to use for local execution.
- Annotations
- @PublicEvolving()
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
def
toString(): String
- Definition Classes
- AnyRef → Any
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @throws( ... )