pyflink.table.catalog.Catalog.alter_partition_statistics

Catalog.alter_partition_statistics(table_path: ObjectPath, partition_spec: CatalogPartitionSpec, partition_statistics: CatalogTableStatistics, ignore_if_not_exists: bool)

Update the statistics of a table partition.

Parameters

• table_path – Path ObjectPath of the table.

• partition_spec – Partition spec CatalogPartitionSpec of the partition.

• partition_statistics – New statistics CatalogTableStatistics to update.

• ignore_if_not_exists – Flag to specify behavior if the partition 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 if the partition does not exist.