pyflink.dataframe.use_catalog

use_catalog(name: str) → None

Set the current catalog for DataFrame operations.

Parameters

name – Catalog name.

Example:

>>> import pyflink.dataframe as pf
>>> pf.use_catalog("my_fluss")
>>> pf.get_current_catalog()
'my_fluss'