pyflink.dataframe.use_database

use_database(name: str) → None

Set the current database for DataFrame operations.

Parameters

name – Database name.

Example:

>>> import pyflink.dataframe as pf
>>> pf.use_database("my_database")
>>> pf.get_current_database()
'my_database'