pyflink.table.table_environment.TableEnvironment.register_catalog

TableEnvironment.register_catalog(catalog_name: str, catalog: pyflink.table.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.