pyflink.dataframe.get_current_database

get_current_database() → str

Get the current database used by DataFrame operations.

Returns

The current database name.

Example:

>>> import pyflink.dataframe as pf
>>> pf.get_current_database()
'default_database'