pyflink.table.catalog.CatalogBaseTable.create_table

static CatalogBaseTable.create_table(schema: TableSchema, partition_keys: List[str] = [], properties: Dict[str, str] = {}, comment: str | None = None) → CatalogBaseTable

Create an instance of CatalogBaseTable for the catalog table.

Parameters:

• schema – the table schema

• partition_keys – the partition keys, default empty

• properties – the properties of the catalog table

• comment – the comment of the catalog table