pyflink.table.catalog.Catalog.bulk_get_partition_column_statistics

Catalog.bulk_get_partition_column_statistics(table_path: pyflink.table.catalog.ObjectPath, partition_specs: List[pyflink.table.catalog.CatalogPartitionSpec]) → List[pyflink.table.catalog.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.