pyflink.table.catalog.Catalog.get_partition

Catalog.get_partition(table_path: ObjectPath, partition_spec: CatalogPartitionSpec) → CatalogPartition

Get a partition of the given table. The given partition spec keys and values need to be matched exactly for a result.

Parameters

• table_path – Path ObjectPath of the table.

• partition_spec – The partition spec CatalogPartitionSpec of partition to get.

Returns

The requested partition CatalogPartition.

Raise

CatalogException in case of any runtime exception. PartitionNotExistException thrown if the partition doesn’t exist.