pyflink.table.catalog.Catalog.bulk_get_partition_column_statistics

Catalog.bulk_get_partition_column_statistics(table_path: ObjectPath, partition_specs: List[CatalogPartitionSpec]) → List[CatalogColumnStatistics]

Get a list of the column statistics for the given partitions.

Parameters:

• table_path – Path ObjectPath of the table.

• partition_specs – The list of CatalogPartitionSpec of the given partitions.

Returns:

The statistics list of CatalogTableStatistics of the given partitions.

Raise:

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