pyflink.table.catalog.CatalogBaseTable.create_table

static CatalogBaseTable.create_table(schema: pyflink.table.table_schema.TableSchema, partition_keys: List[str] = [], properties: Dict[str, str] = {}, comment: Optional[str] = None) → pyflink.table.catalog.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