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 flink-conf.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.