pyflink.table.table_environment.StreamTableEnvironment.register_catalog

StreamTableEnvironment.register_catalog(catalog_name: str, catalog: Catalog)

Registers a Catalog under a unique name. All tables registered in the Catalog can be accessed.

Parameters

• catalog_name – The name under which the catalog will be registered.

• catalog – The catalog to register.