- static StreamExecutionEnvironment.get_execution_environment(configuration: Optional[pyflink.common.configuration.Configuration] = None) pyflink.datastream.stream_execution_environment.StreamExecutionEnvironment [source]#
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.
configuration – The configuration to instantiate the environment with.
The execution environment of the context in which the program is executed.