pyflink.dataframe.get_current_catalog

get_current_catalog() → str

Get the current catalog used by DataFrame operations.

Returns

The current catalog name.

Example:

>>> import pyflink.dataframe as pf
>>> pf.get_current_catalog()
'default_catalog'