pyflink.table.table_environment.StreamTableEnvironment.get_catalog

StreamTableEnvironment.get_catalog(catalog_name: str) → pyflink.table.catalog.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.