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.