pyflink.table.catalog.Catalog.list_partitions

Catalog.list_partitions(table_path: ObjectPath, partition_spec: CatalogPartitionSpec | None = 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.