pyflink.table.catalog.Catalog.drop_partition

Catalog.drop_partition(table_path: ObjectPath, partition_spec: CatalogPartitionSpec, ignore_if_not_exists: bool)

Drop a partition.

Parameters

• table_path – Path ObjectPath of the table.

• partition_spec – Partition spec CatalogPartitionSpec of the partition to drop.

• ignore_if_not_exists – Flag to specify behavior if the database does not exist: if set to false, throw an exception, if set to true, nothing happens.

Raise

CatalogException in case of any runtime exception. PartitionNotExistException thrown if the target partition does not exist.