类 PartitionUtils

Object
io.delta.kernel.utils.PartitionUtils

public class PartitionUtils extends Object
  • 方法详情

    • partitionExists

      public static boolean partitionExists(Engine engine, Snapshot snapshot, Predicate partitionPredicate)
      根据给定的 Predicate 检查给定 Snapshot 中是否存在分区(即实际包含数据)。
      参数
      engine - 用于扫描分区的 Engine
      snapshot - 要扫描的 Snapshot
      partitionPredicate - 用于过滤分区的 Predicate
      返回
      如果分区存在,则为 true,否则为 false。
      抛出
      IllegalArgumentException - 如果谓词未引用任何分区列或引用任何数据列