pyflink.table.catalog.Catalog.alter_partition

Catalog.alter_partition(table_path: ObjectPath, partition_spec: CatalogPartitionSpec, new_partition: CatalogPartition, ignore_if_not_exists: bool)

Alter a partition.

Parameters:

• table_path – Path ObjectPath of the table.

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

• new_partition – New partition CatalogPartition to replace the old one.

• 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.