pyflink.table.catalog.Catalog.get_partition_statistics

Catalog.get_partition_statistics(table_path: ObjectPath, partition_spec: CatalogPartitionSpec) → CatalogTableStatistics

Get the statistics of a partition.

Parameters:

• table_path – Path ObjectPath of the table.

• partition_spec – Partition spec CatalogPartitionSpec of the partition.

Returns:

The statistics CatalogTableStatistics of the given partition.

Raise:

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