pyflink.table.catalog.Catalog.bulk_get_partition_column_statistics#

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

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.