pyflink.table.catalog.Catalog.get_partition_column_statistics

Catalog.get_partition_column_statistics(table_path: ObjectPath, partition_spec: CatalogPartitionSpec) → CatalogColumnStatistics

Get the column statistics of a partition.

Parameters

• table_path – Path ObjectPath of the table.

• partition_spec – Partition spec CatalogPartitionSpec of the partition.

Returns

The column statistics CatalogColumnStatistics of the given partition.

Raise

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