pyflink.table.catalog.Catalog.bulk_get_partition_statistics

Catalog.bulk_get_partition_statistics(table_path: ObjectPath, partition_specs: List[CatalogPartitionSpec]) → List[CatalogTableStatistics]

Get a list of statistics of 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.