pyflink.table.catalog.Catalog.get_partition#

Catalog.get_partition(table_path: ObjectPath, partition_spec: CatalogPartitionSpec) → CatalogPartition[source]#

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.