pyflink.table.catalog.Catalog.list_partitions

Catalog.list_partitions(table_path: ObjectPath, partition_spec: Optional[CatalogPartitionSpec] = None) → List[CatalogPartitionSpec]

Get CatalogPartitionSpec of all partitions of the table.

Parameters

• table_path – Path ObjectPath of the table.

• partition_spec – The partition spec CatalogPartitionSpec to list.

Returns

A list of CatalogPartitionSpec of the table.

Raise

CatalogException in case of any runtime exception. TableNotExistException thrown if the table does not exist in the catalog. TableNotPartitionedException thrown if the table is not partitioned.