pyflink.table.catalog.Catalog.get_default_database

Catalog.get_default_database() → str

Get the name of the default database for this catalog. The default database will be the current database for the catalog when user’s session doesn’t specify a current database. The value probably comes from configuration, will not change for the life time of the catalog instance.

Returns

The name of the current database.

Raise

CatalogException in case of any runtime exception.