c

io.delta.tables

DeltaOptimizeBuilder

类 DeltaOptimizeBuilder 扩展 AnalysisHelper

用于构建 OPTIMIZE 命令并执行的构建器类。

自

2.0.0

线性超类型
AnalysisHelper, AnyRef, Any
排序
  1. 按字母顺序
  2. 按继承顺序
继承
  1. DeltaOptimizeBuilder
  2. AnalysisHelper
  3. AnyRef
  4. Any
  1. 隐藏所有
  2. 显示所有
可见性
  1. 公共
  2. 受保护的

值成员

  1. final def !=(arg0: Any): Boolean
    定义类
    AnyRef → Any
  2. final def ##: Int
    定义类
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    定义类
    AnyRef → Any
  4. final def asInstanceOf[T0]: T0
    定义类
    Any
  5. def clone(): AnyRef
    属性
    protected[lang]
    定义类
    AnyRef
    注解
    @throws(classOf[java.lang.CloneNotSupportedException]) @IntrinsicCandidate() @native()
  6. final def eq(arg0: AnyRef): Boolean
    定义类
    AnyRef
  7. def equals(arg0: AnyRef): Boolean
    定义类
    AnyRef → Any
  8. def executeCompaction(): DataFrame

    压缩选定分区中的小文件。

    压缩选定分区中的小文件。

    返回

    包含 OPTIMIZE 执行指标的 DataFrame

    自

    2.0.0

  9. def executeZOrderBy(columns: String*): DataFrame

    使用给定列对选定分区中的数据进行 Z-Order 排序。

    使用给定列对选定分区中的数据进行 Z-Order 排序。

    列

    零个或多个用于使用 Z-Order 曲线对数据进行排序的列

    返回

    包含 OPTIMIZE 执行指标的 DataFrame

    注解
    @varargs()
    自

    2.0.0

  10. final def getClass(): Class[_ <: AnyRef]
    定义类
    AnyRef → Any
    注解
    @IntrinsicCandidate() @native()
  11. def hashCode(): Int
    定义类
    AnyRef → Any
    注解
    @IntrinsicCandidate() @native()
  12. def improveUnsupportedOpError[T](f: => T): T
    属性
    受保护
    定义类
    AnalysisHelper
  13. final def isInstanceOf[T0]: Boolean
    定义类
    Any
  14. final def ne(arg0: AnyRef): Boolean
    定义类
    AnyRef
  15. final def notify(): Unit
    定义类
    AnyRef
    注解
    @IntrinsicCandidate() @native()
  16. final def notifyAll(): Unit
    定义类
    AnyRef
    注解
    @IntrinsicCandidate() @native()
  17. def resolveReferencesForExpressions(sparkSession: SparkSession, exprs: Seq[Expression], planProvidingAttrs: LogicalPlan): Seq[Expression]
    属性
    受保护
    定义类
    AnalysisHelper
  18. final def synchronized[T0](arg0: => T0): T0
    定义类
    AnyRef
  19. def toDataset(sparkSession: SparkSession, logicalPlan: LogicalPlan): Dataset[Row]
    属性
    受保护
    定义类
    AnalysisHelper
  20. def toString(): String
    定义类
    AnyRef → Any
  21. def tryResolveReferences(sparkSession: SparkSession)(expr: Expression, planContainingExpr: LogicalPlan): Expression
    属性
    受保护
    定义类
    AnalysisHelper
  22. def tryResolveReferencesForExpressions(sparkSession: SparkSession)(exprs: Seq[Expression], plansProvidingAttrs: Seq[LogicalPlan]): Seq[Expression]
    属性
    受保护
    定义类
    AnalysisHelper
  23. def tryResolveReferencesForExpressions(sparkSession: SparkSession, exprs: Seq[Expression], planContainingExpr: LogicalPlan): Seq[Expression]
    属性
    受保护
    定义类
    AnalysisHelper
  24. final def wait(arg0: Long, arg1: Int): Unit
    定义类
    AnyRef
    注解
    @throws(classOf[java.lang.InterruptedException])
  25. final def wait(arg0: Long): Unit
    定义类
    AnyRef
    注解
    @throws(classOf[java.lang.InterruptedException]) @native()
  26. final def wait(): Unit
    定义类
    AnyRef
    注解
    @throws(classOf[java.lang.InterruptedException])
  27. def where(partitionFilter: String): DeltaOptimizeBuilder

    在此优化命令构建器上应用分区过滤器，以限制在选定分区上的操作。

    在此优化命令构建器上应用分区过滤器，以限制在选定分区上的操作。

    分区过滤器

    要应用的分区过滤器

    返回

    应用分区过滤器后的 DeltaOptimizeBuilder

    自

    2.0.0

已弃用的值成员

  1. def finalize(): Unit
    属性
    protected[lang]
    定义类
    AnyRef
    注解
    @throws(classOf[java.lang.Throwable]) @Deprecated
    已弃用

    (版本 9 起)

继承自 AnalysisHelper

继承自 AnyRef

继承自 Any

未分组