pyflink.dataframe.context.DataFrameConfig

class DataFrameConfig

Configuration for DataFrame operations.

Stores key-value config pairs and applies them to the underlying TableEnvironment. If a TableEnvironment is already set, configs are applied immediately. Otherwise, they are buffered and applied when the environment becomes available.

Example::

>>> import pyflink.dataframe as pf
>>> pf.config.set("parallelism.default", "4")
>>> pf.config.get("parallelism.default")
'4'

Methods

get(key[, default])	Get a configuration value.
set(key, value)	Set a configuration key-value pair.