pyflink.dataframe.create_catalog

create_catalog(name: str, options: Mapping[str, Any]) → None

Create a catalog in the DataFrame default TableEnvironment.

Parameters

• name – Catalog name.

• options – Catalog options. Keys and values are converted to strings.

Example:

>>> import pyflink.dataframe as pf
>>> pf.create_catalog("my_fluss", {
...         "type": "fluss",
...         "bootstrap.servers": "localhost:9123",
...     },
... )