org.apache.flink.api.scala

ExecutionEnvironment

object ExecutionEnvironment

Annotations
@Public()
Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. ExecutionEnvironment
  2. AnyRef
  3. Any
  1. Hide All
  2. Show all
Learn more about member selection
Visibility
  1. Public
  2. All

Value Members

  1. final def !=(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  2. final def !=(arg0: Any): Boolean

    Definition Classes
    Any
  3. final def ##(): Int

    Definition Classes
    AnyRef → Any
  4. final def ==(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  5. final def ==(arg0: Any): Boolean

    Definition Classes
    Any
  6. final def asInstanceOf[T0]: T0

    Definition Classes
    Any
  7. def clone(): AnyRef

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  8. 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.

    returns

    Annotations
    @PublicEvolving()
  9. 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.

  10. def createLocalEnvironment(parallelism: Int = ...): 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. The parallelism of the local environment is the number of hardware contexts (CPU cores/threads).

  11. 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 Akka specific configuration parameters for the Client only; Program parallelism can be set via ExecutionEnvironment.setParallelism.

    Cluster 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.

  12. 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.

  13. 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.

  14. final def eq(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  15. def equals(arg0: Any): Boolean

    Definition Classes
    AnyRef → Any
  16. def finalize(): Unit

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  17. final def getClass(): Class[_]

    Definition Classes
    AnyRef → Any
  18. 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.

  19. def hashCode(): Int

    Definition Classes
    AnyRef → Any
  20. final def isInstanceOf[T0]: Boolean

    Definition Classes
    Any
  21. final def ne(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  22. final def notify(): Unit

    Definition Classes
    AnyRef
  23. final def notifyAll(): Unit

    Definition Classes
    AnyRef
  24. final def synchronized[T0](arg0: ⇒ T0): T0

    Definition Classes
    AnyRef
  25. def toString(): String

    Definition Classes
    AnyRef → Any
  26. final def wait(): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  27. final def wait(arg0: Long, arg1: Int): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  28. final def wait(arg0: Long): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

Inherited from AnyRef

Inherited from Any

Ungrouped