pyflink.table.table_environment.StreamTableEnvironment.get_catalog

StreamTableEnvironment.get_catalog(catalog_name: str) → Catalog

Gets a registered Catalog by name.

Parameters:

catalog_name – The name to look up the Catalog.

Returns:

The requested catalog, None if there is no registered catalog with given name.