Package io.delta.kernel.utils

Class PartitionUtils

Object

io.delta.kernel.utils.PartitionUtils

public class PartitionUtils
extends Object

Method Summary

Modifier and Type	Method	Description
static boolean	partitionExists(Engine engine, Snapshot snapshot, Predicate partitionPredicate)	Check if a partition exists (i.e.

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

partitionExists

public static boolean partitionExists(Engine engine,
 Snapshot snapshot,
 Predicate partitionPredicate)

Check if a partition exists (i.e. actually has data) in the given Snapshot based on the given Predicate.

Parameters:

engine - the Engine to use for scanning the partition.

snapshot - the Snapshot to scan.

partitionPredicate - the Predicate to use for filtering the partition.

Returns:

true if the partition exists, false otherwise.

Throws:

IllegalArgumentException - if the predicate does not reference any partition columns or if it references any data columns