索引
所有类和接口|所有包|序列化形式
A
- addColumn(String, String) - 类 io.delta.tables.DeltaTableBuilder 中的方法
-
:: 演进中 :
- addColumn(String, String, boolean) - 类 io.delta.tables.DeltaTableBuilder 中的方法
-
:: 演进中 :
- addColumn(String, DataType) - 类 io.delta.tables.DeltaTableBuilder 中的方法
-
:: 演进中 :
- addColumn(String, DataType, boolean) - 类 io.delta.tables.DeltaTableBuilder 中的方法
-
:: 演进中 :
- addColumn(StructField) - 类 io.delta.tables.DeltaTableBuilder 中的方法
-
:: 演进中 :
- addColumns(StructType) - 类 io.delta.tables.DeltaTableBuilder 中的方法
-
:: 演进中 :
- addFeatureSupport(String) - 类 io.delta.tables.DeltaTable 中的方法
-
修改协议以添加支持的功能,如果表不支持表功能,则自动升级协议。
- alias(String) - 类 io.delta.tables.DeltaTable 中的方法
-
为 DeltaTable 应用别名。
- as(String) - 类 io.delta.tables.DeltaTable 中的方法
-
为 DeltaTable 应用别名。
B
- build() - 类 io.delta.tables.DeltaColumnBuilder 中的方法
-
:: 演进中 :
C
- clone(String, boolean) - 类 io.delta.tables.DeltaTable 中的方法
-
将 DeltaTable 克隆到给定目的地,以镜像现有表的数据和元数据。
- clone(String, boolean, boolean) - 类 io.delta.tables.DeltaTable 中的方法
-
将 DeltaTable 克隆到给定目的地,以镜像现有表的数据和元数据。
- clone(String, boolean, boolean, HashMap<String, String>) - 类 io.delta.tables.DeltaTable 中的方法
-
Python 实现使用 java.util.HashMap 作为 properties 参数的克隆。
- clone(String, boolean, boolean, Map<String, String>) - 类 io.delta.tables.DeltaTable 中的方法
-
将 DeltaTable 克隆到给定目的地,以镜像现有表的数据和元数据。
- cloneAtTimestamp(String, String, boolean) - 类 io.delta.tables.DeltaTable 中的方法
-
将指定时间戳的 DeltaTable 克隆到给定目的地,以镜像该时间戳的现有表的数据和元数据。
- cloneAtTimestamp(String, String, boolean, boolean) - 类 io.delta.tables.DeltaTable 中的方法
-
将指定时间戳的 DeltaTable 克隆到给定目的地,以镜像该时间戳的现有表的数据和元数据。
- cloneAtTimestamp(String, String, boolean, boolean, HashMap<String, String>) - 类 io.delta.tables.DeltaTable 中的方法
-
Python 实现使用 java.util.HashMap 作为 properties 参数的 cloneAtTimestamp。
- cloneAtTimestamp(String, String, boolean, boolean, Map<String, String>) - 类 io.delta.tables.DeltaTable 中的方法
-
将指定时间戳的 DeltaTable 克隆到给定目的地,以镜像该时间戳的现有表的数据和元数据。
- cloneAtVersion(long, String, boolean) - 类 io.delta.tables.DeltaTable 中的方法
-
将指定版本的 DeltaTable 克隆到给定目的地,以镜像该版本现有表的数据和元数据。
- cloneAtVersion(long, String, boolean, boolean) - 类 io.delta.tables.DeltaTable 中的方法
-
将指定版本的 DeltaTable 克隆到给定目的地,以镜像该版本现有表的数据和元数据。
- cloneAtVersion(long, String, boolean, boolean, HashMap<String, String>) - 类 io.delta.tables.DeltaTable 中的方法
-
Python 实现使用 java.util.HashMap 作为 properties 参数的 cloneAtVersion。
- cloneAtVersion(long, String, boolean, boolean, Map<String, String>) - 类 io.delta.tables.DeltaTable 中的方法
-
将指定版本的 DeltaTable 克隆到给定目的地,以镜像该版本现有表的数据和元数据。
- clusterBy(String...) - 类 io.delta.tables.DeltaTableBuilder 中的方法
-
:: 演进中 :
- clusterBy(Seq<String>) - 类 io.delta.tables.DeltaTableBuilder 中的方法
-
:: 演进中 :
- columnBuilder(String) - 类 io.delta.tables.DeltaTable 中的静态方法
-
:: 演进中 :
- columnBuilder(SparkSession, String) - 类 io.delta.tables.DeltaTable 中的静态方法
-
:: 演进中 :
- comment(String) - 类 io.delta.tables.DeltaColumnBuilder 中的方法
-
:: 演进中 :
- comment(String) - 类 io.delta.tables.DeltaTableBuilder 中的方法
-
:: 演进中 :
- ConcurrentAppendException - io.delta.exceptions 包中的异常
-
:: 演进中 :
- ConcurrentAppendException(String) - 异常 io.delta.exceptions.ConcurrentAppendException 的构造函数
- ConcurrentAppendException(String[]) - 异常 io.delta.exceptions.ConcurrentAppendException 的构造函数
- ConcurrentDeleteDeleteException - io.delta.exceptions 包中的异常
-
:: 演进中 :
- ConcurrentDeleteDeleteException(String) - 异常 io.delta.exceptions.ConcurrentDeleteDeleteException 的构造函数
- ConcurrentDeleteDeleteException(String[]) - 异常 io.delta.exceptions.ConcurrentDeleteDeleteException 的构造函数
- ConcurrentDeleteReadException - io.delta.exceptions 包中的异常
-
:: 演进中 :
- ConcurrentDeleteReadException(String) - 异常 io.delta.exceptions.ConcurrentDeleteReadException 的构造函数
- ConcurrentDeleteReadException(String[]) - 异常 io.delta.exceptions.ConcurrentDeleteReadException 的构造函数
- ConcurrentTransactionException - io.delta.exceptions 包中的异常
-
:: 演进中 :
- ConcurrentTransactionException(String) - 异常 io.delta.exceptions.ConcurrentTransactionException 的构造函数
- ConcurrentTransactionException(String[]) - 异常 io.delta.exceptions.ConcurrentTransactionException 的构造函数
- ConcurrentWriteException - io.delta.exceptions 包中的异常
-
:: 演进中 :
- ConcurrentWriteException(String) - 异常 io.delta.exceptions.ConcurrentWriteException 的构造函数
- ConcurrentWriteException(String[]) - 异常 io.delta.exceptions.ConcurrentWriteException 的构造函数
- convertToDelta(SparkSession, String) - 类 io.delta.tables.DeltaTable 中的静态方法
-
从给定的 parquet 表创建 DeltaTable。
- convertToDelta(SparkSession, String, String) - 类 io.delta.tables.DeltaTable 中的静态方法
-
从给定的 parquet 表和分区模式创建 DeltaTable。
- convertToDelta(SparkSession, String, StructType) - 类 io.delta.tables.DeltaTable 中的静态方法
-
从给定的 parquet 表和分区模式创建 DeltaTable。
- create() - 类 io.delta.tables.DeltaTable 中的静态方法
-
:: 演进中 :
- create(SparkSession) - 类 io.delta.tables.DeltaTable 中的静态方法
-
:: 演进中 :
- createIfNotExists() - 类 io.delta.tables.DeltaTable 中的静态方法
-
:: 演进中 :
- createIfNotExists(SparkSession) - 类 io.delta.tables.DeltaTable 中的静态方法
-
:: 演进中 :
- createOrReplace() - 类 io.delta.tables.DeltaTable 中的静态方法
-
:: 演进中 :
- createOrReplace(SparkSession) - 类 io.delta.tables.DeltaTable 中的静态方法
-
:: 演进中 :
D
- dataType(String) - 类 io.delta.tables.DeltaColumnBuilder 中的方法
-
:: 演进中 :
- dataType(DataType) - 类 io.delta.tables.DeltaColumnBuilder 中的方法
-
:: 演进中 :
- delete() - 类 io.delta.tables.DeltaMergeMatchedActionBuilder 中的方法
-
从表中删除匹配的行。
- delete() - 类 io.delta.tables.DeltaMergeNotMatchedBySourceActionBuilder 中的方法
-
从目标表中删除不匹配的行。
- delete() - 类 io.delta.tables.DeltaTable 中的方法
-
从表中删除数据。
- delete(String) - 类 io.delta.tables.DeltaTable 中的方法
-
从表中删除与给定 `condition` 匹配的数据。
- delete(Column) - 类 io.delta.tables.DeltaTable 中的方法
-
从表中删除与给定 `condition` 匹配的数据。
- DeltaColumnBuilder - io.delta.tables 包中的类
-
:: 演进中 :
- DeltaConcurrentModificationException - io.delta.exceptions 包中的异常
-
:: 演进中 :
- DeltaConcurrentModificationException(String) - 异常 io.delta.exceptions.DeltaConcurrentModificationException 的构造函数
- DeltaMergeBuilder - io.delta.tables 包中的类
-
用于指定如何将数据从源 DataFrame 合并到目标 Delta 表的构建器。
- DeltaMergeBuilder(DeltaTable, Dataset<Row>, Column, Seq<DeltaMergeIntoClause>) - 类 io.delta.tables.DeltaMergeBuilder 的构造函数
- DeltaMergeMatchedActionBuilder - io.delta.tables 包中的类
-
构建器类,用于指定当目标表行根据给定的合并条件和可选匹配条件匹配源行时要执行的操作。
- DeltaMergeMatchedActionBuilder() - 类 io.delta.tables.DeltaMergeMatchedActionBuilder 的构造函数
- DeltaMergeNotMatchedActionBuilder - io.delta.tables 包中的类
-
构建器类,用于指定当源行未根据合并条件匹配任何目标 Delta 表行,但如果指定了附加条件,则匹配该条件时要执行的操作。
- DeltaMergeNotMatchedActionBuilder() - 类 io.delta.tables.DeltaMergeNotMatchedActionBuilder 的构造函数
- DeltaMergeNotMatchedBySourceActionBuilder - io.delta.tables 包中的类
-
构建器类,用于指定当目标表行在源表中没有匹配项时(根据给定的合并条件和可选匹配条件)要执行的操作。
- DeltaMergeNotMatchedBySourceActionBuilder() - 类 io.delta.tables.DeltaMergeNotMatchedBySourceActionBuilder 的构造函数
- DeltaOptimizeBuilder - io.delta.tables 包中的类
-
用于构建 OPTIMIZE 命令并执行的构建器类。
- DeltaOptimizeBuilder() - 类 io.delta.tables.DeltaOptimizeBuilder 的构造函数
- DeltaTable - io.delta.tables 包中的类
-
用于以编程方式与 Delta 表交互的主类。
- DeltaTableBuilder - io.delta.tables 包中的类
-
:: 演进中 :
- detail() - 类 io.delta.tables.DeltaTable 中的方法
-
:: 演进中 :
- dropFeatureSupport(String) - 类 io.delta.tables.DeltaTable 中的方法
-
修改协议以删除支持的功能。
- dropFeatureSupport(String, boolean) - 类 io.delta.tables.DeltaTable 中的方法
-
修改协议以删除支持的功能。
E
- execute() - 类 io.delta.tables.DeltaMergeBuilder 中的方法
-
根据构建的匹配和不匹配操作执行合并操作。
- execute() - 类 io.delta.tables.DeltaTableBuilder 中的方法
-
:: 演进中 :
- executeCompaction() - 类 io.delta.tables.DeltaOptimizeBuilder 中的方法
-
压缩选定分区中的小文件。
- executeZOrderBy(String...) - 类 io.delta.tables.DeltaOptimizeBuilder 中的方法
-
使用给定列对选定分区中的数据进行 Z-Order 排序。
- executeZOrderBy(Seq<String>) - 类 io.delta.tables.DeltaOptimizeBuilder 中的方法
-
使用给定列对选定分区中的数据进行 Z-Order 排序。
F
- forName(String) - 类 io.delta.tables.DeltaTable 中的静态方法
-
使用给定的表名实例化
DeltaTable
对象。 - forName(SparkSession, String) - 类 io.delta.tables.DeltaTable 中的静态方法
-
使用以下方法之一实例化
DeltaTable
对象:1。 - forPath(String) - 类 io.delta.tables.DeltaTable 中的静态方法
-
实例化表示给定路径数据的
DeltaTable
对象。如果给定路径无效(即 - forPath(SparkSession, String) - 类 io.delta.tables.DeltaTable 中的静态方法
-
实例化表示给定路径数据的
DeltaTable
对象。如果给定路径无效(即 - forPath(SparkSession, String, Map<String, String>) - 类 io.delta.tables.DeltaTable 中的静态方法
-
Java 友好型 API,用于实例化表示给定路径数据的
DeltaTable
对象。如果给定路径无效(即 - forPath(SparkSession, String, Map<String, String>) - 类 io.delta.tables.DeltaTable 中的静态方法
-
实例化表示给定路径数据的
DeltaTable
对象。如果给定路径无效(即
G
- generate(String) - 类 io.delta.tables.DeltaTable 中的方法
-
为给定的 Delta 表生成清单
- generatedAlwaysAs(String) - 类 io.delta.tables.DeltaColumnBuilder 中的方法
-
:: 演进中 :
- generatedAlwaysAsIdentity() - 类 io.delta.tables.DeltaColumnBuilder 中的方法
-
:: 演进中 :
- generatedAlwaysAsIdentity(long, long) - 类 io.delta.tables.DeltaColumnBuilder 中的方法
-
:: 演进中 :
- generatedByDefaultAsIdentity() - 类 io.delta.tables.DeltaColumnBuilder 中的方法
-
:: 演进中 :
- generatedByDefaultAsIdentity(long, long) - 类 io.delta.tables.DeltaColumnBuilder 中的方法
-
:: 演进中 :
- getErrorClass() - 异常 io.delta.exceptions.ConcurrentAppendException 中的方法
- getErrorClass() - 异常 io.delta.exceptions.ConcurrentDeleteDeleteException 中的方法
- getErrorClass() - 异常 io.delta.exceptions.ConcurrentDeleteReadException 中的方法
- getErrorClass() - 异常 io.delta.exceptions.ConcurrentTransactionException 中的方法
- getErrorClass() - 异常 io.delta.exceptions.ConcurrentWriteException 中的方法
- getErrorClass() - 异常 io.delta.exceptions.MetadataChangedException 中的方法
- getErrorClass() - 异常 io.delta.exceptions.ProtocolChangedException 中的方法
- getMessage() - 异常 io.delta.exceptions.ConcurrentAppendException 中的方法
- getMessage() - 异常 io.delta.exceptions.ConcurrentDeleteDeleteException 中的方法
- getMessage() - 异常 io.delta.exceptions.ConcurrentDeleteReadException 中的方法
- getMessage() - 异常 io.delta.exceptions.ConcurrentTransactionException 中的方法
- getMessage() - 异常 io.delta.exceptions.ConcurrentWriteException 中的方法
- getMessage() - 异常 io.delta.exceptions.MetadataChangedException 中的方法
- getMessage() - 异常 io.delta.exceptions.ProtocolChangedException 中的方法
H
- history() - 类 io.delta.tables.DeltaTable 中的方法
-
获取此表上可用提交的信息作为 Spark DataFrame。
- history(int) - 类 io.delta.tables.DeltaTable 中的方法
-
获取此表上最新 `limit` 提交的信息作为 Spark DataFrame。
I
- insert(Map<String, Column>) - 类 io.delta.tables.DeltaMergeNotMatchedActionBuilder 中的方法
-
根据 `values` 定义的规则向目标表插入新行。
- insert(Map<String, Column>) - 类 io.delta.tables.DeltaMergeNotMatchedActionBuilder 中的方法
-
根据 `values` 定义的规则向目标表插入新行。
- insertAll() - 类 io.delta.tables.DeltaMergeNotMatchedActionBuilder 中的方法
-
通过将目标列分配给源行中相应列的值来插入新的目标 Delta 表行。
- insertExpr(Map<String, String>) - 类 io.delta.tables.DeltaMergeNotMatchedActionBuilder 中的方法
-
根据 `values` 定义的规则向目标表插入新行。
- insertExpr(Map<String, String>) - 类 io.delta.tables.DeltaMergeNotMatchedActionBuilder 中的方法
-
根据 `values` 定义的规则向目标表插入新行。
- io.delta.exceptions - 包 io.delta.exceptions
- io.delta.tables - 包 io.delta.tables
- isDeltaTable(String) - 类 io.delta.tables.DeltaTable 中的静态方法
-
检查提供的 `identifier` 字符串(在这种情况下是文件路径)是否是 Delta 表的根目录。
- isDeltaTable(SparkSession, String) - 类 io.delta.tables.DeltaTable 中的静态方法
-
使用给定的 SparkSession 检查提供的 `identifier` 字符串(在这种情况下是文件路径)是否是 Delta 表的根目录。
L
- location(String) - 类 io.delta.tables.DeltaTableBuilder 中的方法
-
:: 演进中 :
M
- merge(Dataset<Row>, String) - 类 io.delta.tables.DeltaTable 中的方法
-
根据给定的合并 `condition` 合并来自 `source` DataFrame 的数据。
- merge(Dataset<Row>, Column) - 类 io.delta.tables.DeltaTable 中的方法
-
根据给定的合并 `condition` 合并来自 `source` DataFrame 的数据。
- MetadataChangedException - io.delta.exceptions 包中的异常
-
:: 演进中 :
- MetadataChangedException(String) - 异常 io.delta.exceptions.MetadataChangedException 的构造函数
- MetadataChangedException(String[]) - 异常 io.delta.exceptions.MetadataChangedException 的构造函数
N
- nullable(boolean) - 类 io.delta.tables.DeltaColumnBuilder 中的方法
-
:: 演进中 :
O
- optimize() - 类 io.delta.tables.DeltaTable 中的方法
-
优化表的数据布局。
P
- partitionedBy(String...) - 类 io.delta.tables.DeltaTableBuilder 中的方法
-
:: 演进中 :
- partitionedBy(Seq<String>) - 类 io.delta.tables.DeltaTableBuilder 中的方法
-
:: 演进中 :
- property(String, String) - 类 io.delta.tables.DeltaTableBuilder 中的方法
-
:: 演进中 :
- ProtocolChangedException - io.delta.exceptions 包中的异常
-
:: 演进中 :
- ProtocolChangedException(String) - 异常 io.delta.exceptions.ProtocolChangedException 的构造函数
- ProtocolChangedException(String[]) - 异常 io.delta.exceptions.ProtocolChangedException 的构造函数
R
- replace() - 类 io.delta.tables.DeltaTable 中的静态方法
-
:: 演进中 :
- replace(SparkSession) - 类 io.delta.tables.DeltaTable 中的静态方法
-
:: 演进中 :
- restoreToTimestamp(String) - 类 io.delta.tables.DeltaTable 中的方法
-
将 DeltaTable 恢复到由时间戳指定的表的旧版本。
- restoreToVersion(long) - 类 io.delta.tables.DeltaTable 中的方法
-
将 DeltaTable 恢复到由版本号指定的表的旧版本。
T
- tableName(String) - 类 io.delta.tables.DeltaTableBuilder 中的方法
-
:: 演进中 :
- toDF() - 类 io.delta.tables.DeltaTable 中的方法
-
获取此 Delta 表的 DataFrame(即 Dataset[Row])表示。
U
- update(Map<String, Column>) - 类 io.delta.tables.DeltaMergeMatchedActionBuilder 中的方法
-
根据 `set` 定义的规则更新匹配的表行。
- update(Map<String, Column>) - 类 io.delta.tables.DeltaMergeNotMatchedBySourceActionBuilder 中的方法
-
根据 `set` 定义的规则更新不匹配的目标表行。
- update(Map<String, Column>) - 类 io.delta.tables.DeltaTable 中的方法
-
根据 `set` 定义的规则更新表中的行。
- update(Column, Map<String, Column>) - 类 io.delta.tables.DeltaTable 中的方法
-
根据 `set` 定义的规则,从表中更新与给定 `condition` 匹配的行数据。
- update(Column, Map<String, Column>) - 类 io.delta.tables.DeltaTable 中的方法
-
根据 `set` 定义的规则,从表中更新与给定 `condition` 匹配的行数据。
- update(Map<String, Column>) - 类 io.delta.tables.DeltaTable 中的方法
-
根据 `set` 定义的规则更新表中的行。
- update(Map<String, Column>) - 类 io.delta.tables.DeltaMergeMatchedActionBuilder 中的方法
-
根据 `set` 定义的规则更新匹配的表行。
- update(Map<String, Column>) - 类 io.delta.tables.DeltaMergeNotMatchedBySourceActionBuilder 中的方法
-
根据 `set` 定义的规则更新不匹配的目标表行。
- updateAll() - 类 io.delta.tables.DeltaMergeMatchedActionBuilder 中的方法
-
将匹配表行的所有列更新为源行中相应列的值。
- updateExpr(String, Map<String, String>) - 类 io.delta.tables.DeltaTable 中的方法
-
根据给定 `condition` 匹配的行数据进行更新,执行 `set` 定义的规则。
- updateExpr(String, Map<String, String>) - 类 io.delta.tables.DeltaTable 中的方法
-
根据给定 `condition` 匹配的行数据进行更新,执行 `set` 定义的规则。
- updateExpr(Map<String, String>) - 类 io.delta.tables.DeltaMergeMatchedActionBuilder 中的方法
-
根据 `set` 定义的规则更新匹配的表行。
- updateExpr(Map<String, String>) - 类 io.delta.tables.DeltaMergeNotMatchedBySourceActionBuilder 中的方法
-
根据 `set` 定义的规则更新不匹配的目标表行。
- updateExpr(Map<String, String>) - 类 io.delta.tables.DeltaTable 中的方法
-
根据 `set` 定义的规则更新表中的行。
- updateExpr(Map<String, String>) - 类 io.delta.tables.DeltaTable 中的方法
-
根据 `set` 定义的规则更新表中的行。
- updateExpr(Map<String, String>) - 类 io.delta.tables.DeltaMergeMatchedActionBuilder 中的方法
-
根据 `set` 定义的规则更新匹配的表行。
- updateExpr(Map<String, String>) - 类 io.delta.tables.DeltaMergeNotMatchedBySourceActionBuilder 中的方法
-
根据 `set` 定义的规则更新不匹配的目标表行。
- upgradeTableProtocol(int, int) - 类 io.delta.tables.DeltaTable 中的方法
-
更新表的协议版本以利用新功能。
V
- vacuum() - 类 io.delta.tables.DeltaTable 中的方法
-
递归删除表中不需要的、用于维护旧版本(直到给定的保留阈值)的文件和目录。
- vacuum(double) - 类 io.delta.tables.DeltaTable 中的方法
-
递归删除表中不需要的、用于维护旧版本(直到给定的保留阈值)的文件和目录。
W
- whenMatched() - 类 io.delta.tables.DeltaMergeBuilder 中的方法
-
当合并条件匹配时,构建要执行的操作。
- whenMatched(String) - 类 io.delta.tables.DeltaMergeBuilder 中的方法
-
当合并条件匹配且给定 `condition` 为 true 时,构建要执行的操作。
- whenMatched(Column) - 类 io.delta.tables.DeltaMergeBuilder 中的方法
-
当合并条件匹配且给定 `condition` 为 true 时,构建要执行的操作。
- whenNotMatched() - 类 io.delta.tables.DeltaMergeBuilder 中的方法
-
当合并条件不匹配时,构建要执行的操作。
- whenNotMatched(String) - 类 io.delta.tables.DeltaMergeBuilder 中的方法
-
当合并条件不匹配且给定 `condition` 为 true 时,构建要执行的操作。
- whenNotMatched(Column) - 类 io.delta.tables.DeltaMergeBuilder 中的方法
-
当合并条件不匹配且给定 `condition` 为 true 时,构建要执行的操作。
- whenNotMatchedBySource() - 类 io.delta.tables.DeltaMergeBuilder 中的方法
-
当合并条件不被源匹配时,构建要执行的操作。
- whenNotMatchedBySource(String) - 类 io.delta.tables.DeltaMergeBuilder 中的方法
-
当合并条件不被源匹配且给定 `condition` 为 true 时,构建要执行的操作。
- whenNotMatchedBySource(Column) - 类 io.delta.tables.DeltaMergeBuilder 中的方法
-
当合并条件不被源匹配且给定 `condition` 为 true 时,构建要执行的操作。
- where(String) - 类 io.delta.tables.DeltaOptimizeBuilder 中的方法
-
在此优化命令构建器上应用分区过滤器,以限制在选定分区上的操作。
- withSchemaEvolution() - 类 io.delta.tables.DeltaMergeBuilder 中的方法
-
启用合并操作的模式演进。
所有类和接口|所有包|序列化形式