所有类和接口
类
描述
始终评估为
false
的谓词。始终评估为
true
的谓词。AND
表达式表示
array
数据类型用于表示
ColumnVector
中的单个数组值的抽象。所有原始类型
DataType
的基类。表示
byte[]
值的D类型。表示
boolean
类型值的数据类型。表示
byte
类型值的数据类型。尝试在版本
v
创建检查点时抛出,但该版本 v
已存在检查点。扩展 Java
Iterable
接口,提供一种关闭迭代器的方式。Iterator
的可关闭扩展表示在
CloseableIterator
的 CloseableIterator.breakableFilter(Function)
方法中应用筛选条件的结果。标识字符串类型的排序规则。
一种表达式类型,它引用输入中(区分大小写的)列。
表示零行或多行具有相同模式类型的记录。
表示单个列的零个或多个值。
当并发事务都尝试使用通过
TransactionBuilder.withTransactionId(Engine, String, long)
(String)} 设置的相同事务标识符更新表时抛出。当当前事务启动后,并发事务写入数据时抛出此异常。
封装 Delta Lake 表中数据文件的统计信息,并提供将这些统计信息序列化为 JSON 的方法,同时进行基本的物理类型验证。
扩展
FileStatus
以包含附加详细信息,例如 Delta Lake 表中数据文件的列级别统计信息。所有数据类型的基类。
包含向 Delta 表写入数据的上下文。
日期类型,支持“0001-01-01”到“9999-12-31”。
表示
java.math.BigDecimal
值的数据类型。基于 Hadoop API 的
Engine
默认实现。ExpressionHandler
的默认实现基于 Hadoop API 的
FileSystemClient
默认实现。基于 Hadoop API 的
JsonHandler
默认实现。基于 Hadoop API 的
ParquetHandler
默认实现。定义 Delta 操作报告共享的通用字段
尝试删除读取快照中不存在的域元数据时抛出。
表示
double
类型值的数据类型。封装 Delta Kernel 读取 Delta 表所需的所有客户端的接口。
旨在发展为稳定 API,但尚未稳定的 API。
所有 Kernel 表达式的基础接口。
用于实现
Expression
评估器的接口。为 Delta Kernel 提供表达式求值功能。
给定
StructField
的元数据。FieldMetadata
的构建器类。文件 I/O 操作的接口。
表示从给定文件读取一定字节范围的请求。
存储文件大小直方图信息以跟踪文件大小分布及其计数。
用于封装 Delta Lake 表中文件元数据的类。
为 Delta Kernel 提供文件系统相关功能。
表示
ColumnarBatch
的过滤版本。表示
float
类型值的数据类型。基于 Hadoop API 的
FileIO
实现。用于读取文件并获取其元数据的接口。
表示
integer
类型值的数据类型。当为表属性指定非法值时抛出此异常。
当遇到无效表时抛出;表的日志和/或检查点文件处于无效状态。
为 Delta Kernel 提供 JSON 处理功能。
当
Engine
在执行操作时遇到错误时抛出。当 Kernel 由于操作无效或不受支持而无法执行请求的操作时抛出。
一个字面值。
MetricsReporter
的实现,它以信息级别将报告(JSON 格式)记录到 Log4J。表示
long
类型值的数据类型。表示
map
类型的数据类型。表示
ColumnVector
中单个映射值的抽象。当 Delta 表的元数据在事务开始和提交之间发生更改时抛出。
包含给定操作指标的接口
用于向 Delta 表报告操作指标的接口
可以在 Delta 表上执行的操作。
OR
表达式用于写入文件并获取其元数据的接口。
为 Delta Kernel 提供 Parquet 文件相关功能。
根据 Delta 协议规范 将序列化分区值解码为分区类型值的表达式。
扩展
OutputStream
以提供流中的当前位置。在事务提交后执行操作的钩子。
定义谓词标量表达式,它是
ScalarExpression
的扩展,对于每个输入行,它评估为 true、false 或 null。用于在输入批处理上评估
Predicate
并返回包含输入批处理中每行一个值的选择向量(指示该行是否通过谓词)的特殊接口。当 Delta 表的协议在事务开始时间和提交时间之间发生变化时抛出。
表示单条记录
标量 SQL 表达式,接受零个或多个输入,并为每个输入行生成一个输出值。
表示对 Delta 表的扫描。
用于构建
Scan
对象的构建器。存储
ScanReport
的指标结果定义 Scan
MetricsReport
的元数据和指标扩展
InputStream
以提供流中的当前位置并寻找到新位置。表示
short
类型值的数据类型。表示 Delta 表的快照。
存储
SnapshotReport
的指标结果定义快照构建
MetricsReport
的元数据和指标表示
string
类型值的数据类型。表示
StructType
的子字段,具有附加属性和元数据。包含一个或多个列的结构体类型。
表示给定路径的 Delta Lake 表。
尝试在已存在 Delta 表的位置创建 Delta 表时抛出此异常。
当给定位置没有 Delta 表时抛出。
不带时区的时间戳类型表示微秒精度的本地时间,与时区无关。
时间戳类型,支持 [0001-01-01T00:00:00.000000Z, 9999-12-31T23:59:59.999999Z],其中左/右边界是 UTC+00:00 中原始儒略历的日期和时间。
表示修改 Delta 表的事务。
用于创建
Transaction
以修改 Delta 表的构建器。包含成功事务提交的结果。
存储
TransactionReport
的指标结果定义事务的元数据和指标
MetricsReport
指定未知配置键时抛出。
一种逻辑变体类型。