pyflink.table.catalog.Catalog.get_partition_statistics

Catalog.get_partition_statistics(table_path: pyflink.table.catalog.ObjectPath, partition_spec: pyflink.table.catalog.CatalogPartitionSpec) → pyflink.table.catalog.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.