pyflink.table.table_environment.StreamTableEnvironment.get_current_catalog

StreamTableEnvironment.get_current_catalog() → str

Gets the current default catalog name of the current session.

Returns:

The current default catalog name that is used for the path resolution.

See also

use_catalog()