pyflink.datastream.stream_execution_environment.StreamExecutionEnvironment.get_execution_environment

static StreamExecutionEnvironment.get_execution_environment(configuration: Optional[pyflink.common.configuration.Configuration] = None) → pyflink.datastream.stream_execution_environment.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.