Configuration#

Functions and classes for configuring the DataFrame execution environment, including setting the underlying TableEnvironment and managing configuration options.

DataFrameConfig#

The module-level pyflink.dataframe.config is a singleton DataFrameConfig instance. Use it to set configuration options that will be applied to the underlying TableEnvironment.

DataFrameConfig()

Configuration for DataFrame operations.

DataFrameConfig.set(key, value)

Set a configuration key-value pair.

DataFrameConfig.get(key[, default])

Get a configuration value.

Environment#

set_table_environment(t_env)

Set the global TableEnvironment for DataFrame operations.

get_table_environment()

Get the currently set global TableEnvironment.

get_or_create_table_environment()

Return the global TableEnvironment, creating and storing one if needed.