pyflink.table.catalog.Catalog.create_table#

Catalog.create_table(table_path: pyflink.table.catalog.ObjectPath, table: pyflink.table.catalog.CatalogBaseTable, ignore_if_exists: bool)[source]#

Create a new table or view.

Parameters

table_path – Path ObjectPath of the table or view to be created.
table – The table definition CatalogBaseTable.
ignore_if_exists – Flag to specify behavior when a table or view already exists at the given path: if set to false, it throws a TableAlreadyExistException, if set to true, do nothing.

Raise

CatalogException in case of any runtime exception. DatabaseNotExistException if the database in tablePath doesn’t exist. TableAlreadyExistException if table already exists and ignoreIfExists is false.