pyflink.table.catalog.Catalog.partition_exists

Catalog.partition_exists(table_path: ObjectPath, partition_spec: CatalogPartitionSpec) → bool

Check whether a partition exists or not.

Parameters:

• table_path – Path ObjectPath of the table.

• partition_spec – Partition spec CatalogPartitionSpec of the partition to check.

Returns:

true if the partition exists.

Raise:

CatalogException in case of any runtime exception.