pyflink.datastream.stream_execution_environment.StreamExecutionEnvironment.get_execution_environment

static StreamExecutionEnvironment.get_execution_environment(configuration: Configuration | None = None) → StreamExecutionEnvironment

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.

When executed from the command line the given configuration is stacked on top of the global configuration which comes from the config.yaml, potentially overriding duplicated options.

Parameters:

configuration – The configuration to instantiate the environment with.

Returns:

The execution environment of the context in which the program is executed.