- static CatalogBaseTable.create_view(original_query: str, expanded_query: str, schema: pyflink.table.table_schema.TableSchema, properties: Dict[str, str], comment: Optional[str] = None) pyflink.table.catalog.CatalogBaseTable [source]#
Create an instance of CatalogBaseTable for the catalog view.
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