pyflink.table.catalog.Catalog.alter_partition_column_statistics

Catalog.alter_partition_column_statistics(table_path: ObjectPath, partition_spec: CatalogPartitionSpec, column_statistics: CatalogColumnStatistics, ignore_if_not_exists: bool)

Update the column statistics of a table partition.

Parameters:

• table_path – Path ObjectPath of the table.

• partition_spec – Partition spec CatalogPartitionSpec of the partition.

• column_statistics – New column statistics CatalogColumnStatistics 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.