pyflink.dataframe.context.config

config = 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'