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.