pyflink.table.catalog.Catalog.create_table

Catalog.create_table(table_path: ObjectPath, table: CatalogBaseTable, ignore_if_exists: bool)

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.