pyflink.table.catalog.CatalogBaseTable.create_view

static CatalogBaseTable.create_view(original_query: str, expanded_query: str, schema: TableSchema, properties: Dict[str, str], comment: str | None = None) → CatalogBaseTable

Create an instance of CatalogBaseTable for the catalog view.

Parameters:

• original_query – the original text of the view definition

• expanded_query – the expanded text of the original view definition, this is needed because the context such as current DB is lost after the session, in which view is defined, is gone. Expanded query text takes care of the this, as an example.

• schema – the table schema

• properties – the properties of the catalog view

• comment – the comment of the catalog view