pyflink.table.table_environment.StreamTableEnvironment.get_current_database

StreamTableEnvironment.get_current_database() → str

Gets the current default database name of the running session.

Returns

The name of the current database of the current catalog.

See also

use_database()