pyflink.table.catalog.Catalog.partition_exists#

Catalog.partition_exists(table_path: ObjectPath, partition_spec: CatalogPartitionSpec) → bool[source]#

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.