索引

A B C D E F G H I J K L M N O P R S T U V W 
所有类和接口|所有包|常量字段值|序列化形式

A

add(StructField) - 类中的方法 io.delta.kernel.types.StructType
 
add(String, DataType) - 类中的方法 io.delta.kernel.types.StructType
 
add(String, DataType, boolean) - 类中的方法 io.delta.kernel.types.StructType
 
add(String, DataType, boolean, FieldMetadata) - 类中的方法 io.delta.kernel.types.StructType
 
add(String, DataType, FieldMetadata) - 类中的方法 io.delta.kernel.types.StructType
 
addDomainMetadata(String, String) - 接口中的方法 io.delta.kernel.Transaction
提交提供的域元数据作为此事务的一部分。
ALWAYS_FALSE - 静态变量,在类 io.delta.kernel.expressions.AlwaysFalse
 
ALWAYS_TRUE - 静态变量,在类 io.delta.kernel.expressions.AlwaysTrue
 
AlwaysFalse - 类,在包 io.delta.kernel.expressions
始终评估为 false 的谓词。
AlwaysTrue - 类,在包 io.delta.kernel.expressions
始终评估为 true 的谓词。
And - 类,在包 io.delta.kernel.expressions
AND 表达式
And(Predicate, Predicate) - 构造器,用于类 io.delta.kernel.expressions.And
 
appendNestedField(String) - 类中的方法 io.delta.kernel.expressions.Column
返回一个新列,该列将输入列名附加到当前列。
ArrayType - 类,在包 io.delta.kernel.types
表示 array 数据类型
ArrayType(DataType, boolean) - 构造器,用于类 io.delta.kernel.types.ArrayType
 
ArrayType(StructField) - 构造器,用于类 io.delta.kernel.types.ArrayType
 
ArrayValue - 接口,在包 io.delta.kernel.data
用于表示 ColumnVector 中的单个数组值的抽象。
at(int) - 类中的方法 io.delta.kernel.types.StructType
 
available() - 类中的方法 io.delta.kernel.defaults.engine.hadoopio.HadoopSeekableInputStream
 

B

BasePrimitiveType - 类,在包 io.delta.kernel.types
所有原始类型 DataType 的基类。
BINARY - 静态变量,在类 io.delta.kernel.types.BinaryType
 
BinaryType - 类,在包 io.delta.kernel.types
表示 byte[] 值的D类型。
BOOLEAN - 静态变量,在类 io.delta.kernel.types.BooleanType
 
BooleanType - 类,在包 io.delta.kernel.types
表示 boolean 类型值的数据类型。
BREAK - 枚举常量,在枚举类 io.delta.kernel.utils.CloseableIterator.BreakableFilterResult
表示迭代应立即停止,并且 CloseableIterator.breakableFilter(Function) 不应处理任何进一步的元素。
breakableFilter(Function<T, CloseableIterator.BreakableFilterResult>) - 接口中的方法 io.delta.kernel.utils.CloseableIterator
返回一个新的 CloseableIterator,它应用一个基于 CloseableIterator.BreakableFilterResult 的过滤函数来确定此迭代器的元素是应包含还是排除,或者迭代是否应终止。
build() - 接口中的方法 io.delta.kernel.ScanBuilder
 
build() - 类中的方法 io.delta.kernel.types.FieldMetadata.Builder
 
build(Engine) - 接口中的方法 io.delta.kernel.TransactionBuilder
构建事务。
builder() - 静态方法,在类 io.delta.kernel.types.FieldMetadata
 
Builder() - 构造器,用于类 io.delta.kernel.types.FieldMetadata.Builder
 
BYTE - 静态变量,在类 io.delta.kernel.types.ByteType
 
ByteType - 类,在包 io.delta.kernel.types
表示 byte 类型值的数​​据类型。

C

checkpoint(Engine, long) - 接口中的方法 io.delta.kernel.Table
在给定版本对表进行检查点。
CHECKPOINT - 枚举常量,在枚举类 io.delta.kernel.hook.PostCommitHook.PostCommitHookType
在事务提交的版本写入新的检查点。
CheckpointAlreadyExistsException - 异常,在包 io.delta.kernel.exceptions
尝试在版本 v 创建检查点时抛出,但该版本 v 已存在检查点。
CheckpointAlreadyExistsException(long) - 构造器,用于异常 io.delta.kernel.exceptions.CheckpointAlreadyExistsException
 
checksum(Engine, long) - 接口中的方法 io.delta.kernel.Table
计算并写入给定版本表的校验和文件。
CHECKSUM_FULL - 枚举常量,在枚举类 io.delta.kernel.hook.PostCommitHook.PostCommitHookType
在事务提交的版本写入校验和文件。
CHECKSUM_SIMPLE - 枚举常量,在枚举类 io.delta.kernel.hook.PostCommitHook.PostCommitHookType
在事务提交的版本写入校验和文件。
close() - 接口中的方法 io.delta.kernel.data.ColumnVector
清理此列向量的内存。
close() - 类中的方法 io.delta.kernel.defaults.engine.hadoopio.HadoopPositionOutputStream
 
close() - 类中的方法 io.delta.kernel.defaults.engine.hadoopio.HadoopSeekableInputStream
 
CloseableIterable<T> - 接口,在包 io.delta.kernel.utils
扩展 Java Iterable 接口,提供一种关闭迭代器的方式。
CloseableIterator<T> - 接口,在包 io.delta.kernel.utils
Iterator 的可关闭扩展
CloseableIterator.BreakableFilterResult - 枚举类,在包 io.delta.kernel.utils
表示在 CloseableIteratorCloseableIterator.breakableFilter(Function) 方法中应用过滤条件的结果。
CollationIdentifier - 类,在包 io.delta.kernel.types
标识字符串类型的排序规则。
COLLATIONS_METADATA_KEY - 静态变量,在类 io.delta.kernel.types.StructField
 
column(int) - 类中的方法 io.delta.kernel.types.StructType
为给定 ordinal 处的字段创建 Column 表达式
Column - 类,在包 io.delta.kernel.expressions
一种表达式类型,它引用输入中(区分大小写的)列。
Column(String) - 构造器,用于类 io.delta.kernel.expressions.Column
创建用于引用列的列表达式。
Column(String[]) - 构造器,用于类 io.delta.kernel.expressions.Column
创建用于引用嵌套列的列表达式。
ColumnarBatch - 接口,在包 io.delta.kernel.data
表示零行或多行具有相同模式类型的记录。
ColumnVector - 接口,在包 io.delta.kernel.data
表示单个列的零个或多个值。
combine(CloseableIterator<T>) - 接口中的方法 io.delta.kernel.utils.CloseableIterator
将当前迭代器与另一个迭代器合并。
commit(Engine, CloseableIterable<Row>) - 接口中的方法 io.delta.kernel.Transaction
ConcurrentTransactionException - 异常,在包 io.delta.kernel.exceptions
当并发事务都尝试使用通过 TransactionBuilder.withTransactionId(Engine, String, long) (String)} 设置的相同事务标识符更新表时抛出。
ConcurrentTransactionException(String, long, long) - 构造器,用于异常 io.delta.kernel.exceptions.ConcurrentTransactionException
 
ConcurrentWriteException - 异常,在包 io.delta.kernel.exceptions
当当前事务启动后,并发事务写入数据时抛出此异常。
ConcurrentWriteException() - 构造器,用于异常 io.delta.kernel.exceptions.ConcurrentWriteException
 
ConcurrentWriteException(String) - 构造器,用于异常 io.delta.kernel.exceptions.ConcurrentWriteException
 
contains(String) - 类中的方法 io.delta.kernel.types.FieldMetadata
 
containsNull() - 类中的方法 io.delta.kernel.types.ArrayType
 
create(boolean) - 接口中的方法 io.delta.kernel.defaults.engine.fileio.OutputFile
获取用于写入文件的输出流。
create(boolean) - 类中的方法 io.delta.kernel.defaults.engine.hadoopio.HadoopOutputFile
 
create(FileIO) - 静态方法,在类 io.delta.kernel.defaults.engine.DefaultEngine
创建 DefaultEngine 的实例。
create(Configuration) - 静态方法,在类 io.delta.kernel.defaults.engine.DefaultEngine
创建 DefaultEngine 的实例。
CREATE_TABLE - 枚举常量,在枚举类 io.delta.kernel.Operation
在创建表时记录。
createPrimitive(String) - 静态方法,在类 io.delta.kernel.types.BasePrimitiveType
创建原始类型 DataType
createSelectionVector(boolean[], int, int) - 类中的方法 io.delta.kernel.defaults.engine.DefaultExpressionHandler
 
createSelectionVector(boolean[], int, int) - 接口中的方法 io.delta.kernel.engine.ExpressionHandler
在给定 values 数组的值范围之上,创建一个选择向量,一个布尔类型的 ColumnVector
createTransactionBuilder(Engine, String, Operation) - 接口中的方法 io.delta.kernel.Table
创建一个 TransactionBuilder,它可以创建一个 Transaction 对象来修改表。

D

DataFileStatistics - 类,在包 io.delta.kernel.statistics
封装 Delta Lake 表中数据文件的统计信息,并提供将这些统计信息序列化为 JSON 的方法,同时进行基本的物理类型验证。
DataFileStatistics(long, Map<Column, Literal>, Map<Column, Literal>, Map<Column, Long>) - 构造器,用于类 io.delta.kernel.statistics.DataFileStatistics
创建 DataFileStatistics 的新实例。
DataFileStatus - 类,在包 io.delta.kernel.utils
扩展 FileStatus 以包含附加详细信息,例如 Delta Lake 表中数据文件的列级别统计信息。
DataFileStatus(String, long, long, Optional<DataFileStatistics>) - 构造器,用于类 io.delta.kernel.utils.DataFileStatus
创建 DataFileStatus 的新实例。
DataType - 类,在包 io.delta.kernel.types
所有数据类型的基类。
DataType() - 构造器,用于类 io.delta.kernel.types.DataType
 
DataWriteContext - 接口,在包 io.delta.kernel
包含向 Delta 表写入数据的上下文。
DATE - 静态变量,在类 io.delta.kernel.types.DateType
 
DateType - 类,在包 io.delta.kernel.types
日期类型,支持“0001-01-01”到“9999-12-31”。
DecimalType - 类,在包 io.delta.kernel.types
表示 java.math.BigDecimal 值的数据类型。
DecimalType(int, int) - 构造器,用于类 io.delta.kernel.types.DecimalType
 
DefaultEngine - 类,在包 io.delta.kernel.defaults.engine
基于 Hadoop API 的 Engine 默认实现。
DefaultExpressionHandler - 类,在包 io.delta.kernel.defaults.engine
ExpressionHandler 的默认实现
DefaultExpressionHandler() - 构造器,用于类 io.delta.kernel.defaults.engine.DefaultExpressionHandler
 
DefaultFileSystemClient - 类,在包 io.delta.kernel.defaults.engine
基于 Hadoop API 的 FileSystemClient 默认实现。
DefaultFileSystemClient(FileIO) - 构造器,用于类 io.delta.kernel.defaults.engine.DefaultFileSystemClient
创建默认 FileSystemClient 实现的实例。
DefaultJsonHandler - 类,在包 io.delta.kernel.defaults.engine
基于 Hadoop API 的 JsonHandler 默认实现。
DefaultJsonHandler(FileIO) - 构造器,用于类 io.delta.kernel.defaults.engine.DefaultJsonHandler
 
DefaultParquetHandler - 类,在包 io.delta.kernel.defaults.engine
基于 Hadoop API 的 ParquetHandler 默认实现。
DefaultParquetHandler(FileIO) - 构造器,用于类 io.delta.kernel.defaults.engine.DefaultParquetHandler
创建默认 ParquetHandler 实现的实例。
delete(String) - 类中的方法 io.delta.kernel.defaults.engine.DefaultFileSystemClient
 
delete(String) - 接口中的方法 io.delta.kernel.defaults.engine.fileio.FileIO
删除给定路径的文件。
delete(String) - 类中的方法 io.delta.kernel.defaults.engine.hadoopio.HadoopFileIO
 
delete(String) - 接口中的方法 io.delta.kernel.engine.FileSystemClient
删除给定路径的文件。
DeltaOperationReport - 接口,在包 io.delta.kernel.metrics
定义 Delta 操作报告共享的通用字段
DomainDoesNotExistException - 异常,在包 io.delta.kernel.exceptions
尝试删除读取快照中不存在的域元数据时抛出。
DomainDoesNotExistException(String, String, long) - 构造器,用于异常 io.delta.kernel.exceptions.DomainDoesNotExistException
 
DOUBLE - 静态变量,在类 io.delta.kernel.types.DoubleType
 
DoubleType - 类,在包 io.delta.kernel.types
表示 double 类型值的数据类型

E

empty() - 静态方法,在类 io.delta.kernel.types.FieldMetadata
 
emptyIterable() - 静态方法,在接口 io.delta.kernel.utils.CloseableIterable
返回一个空集合的 CloseableIterable 对象。
Engine - 接口,在包 io.delta.kernel.engine
封装 Delta Kernel 读取 Delta 表所需的所有客户端的接口。
equals(Object) - 类中的方法 io.delta.kernel.expressions.Column
 
equals(Object) - 类中的方法 io.delta.kernel.expressions.Literal
 
equals(Object) - 类中的方法 io.delta.kernel.statistics.DataFileStatistics
 
equals(Object) - 类中的方法 io.delta.kernel.types.ArrayType
 
equals(Object) - 类中的方法 io.delta.kernel.types.BasePrimitiveType
 
equals(Object) - 类中的方法 io.delta.kernel.types.CollationIdentifier
当提供者、名称和版本相同时,排序规则标识符相同。
equals(Object) - 类 io.delta.kernel.types.DataType 中的方法
 
equals(Object) - 类 io.delta.kernel.types.DecimalType 中的方法
 
equals(Object) - 类 io.delta.kernel.types.FieldMetadata 中的方法
 
equals(Object) - 类 io.delta.kernel.types.MapType 中的方法
 
equals(Object) - 类 io.delta.kernel.types.StringType 中的方法
 
equals(Object) - 类 io.delta.kernel.types.StructField 中的方法
 
equals(Object) - 类 io.delta.kernel.types.StructType 中的方法
 
equals(Object) - 类 io.delta.kernel.utils.FileStatus 中的方法
 
equivalent(DataType) - 类 io.delta.kernel.types.ArrayType 中的方法
 
equivalent(DataType) - 类 io.delta.kernel.types.DataType 中的方法
数据类型是否相同?元数据或列名可能不同。
equivalent(DataType) - 类 io.delta.kernel.types.MapType 中的方法
 
equivalent(DataType) - 类 io.delta.kernel.types.StructType 中的方法
 
eval(ColumnarBatch) - 接口 io.delta.kernel.expressions.ExpressionEvaluator 中的方法
在给定 ColumnarBatch 数据上评估表达式。
eval(ColumnarBatch, Optional<ColumnVector>) - 接口 io.delta.kernel.expressions.PredicateEvaluator 中的方法
在给定 inputData 上评估谓词。
Evolving - io.delta.kernel.annotation 中的注解接口
旨在发展为稳定 API,但尚未稳定的 API。
EXCLUDE - 枚举类 io.delta.kernel.utils.CloseableIterator.BreakableFilterResult 中的枚举常量
表示当前元素应从 CloseableIterator.breakableFilter(Function) 生成的结果迭代器中排除。
Expression - io.delta.kernel.expressions 中的接口
所有 Kernel 表达式的基础接口。
ExpressionEvaluator - io.delta.kernel.expressions 中的接口
用于实现 Expression 评估器的接口。
ExpressionHandler - io.delta.kernel.engine 中的接口
为 Delta Kernel 提供表达式求值功能。

F

FieldMetadata - io.delta.kernel.types 中的类
给定 StructField 的元数据。
FieldMetadata.Builder - io.delta.kernel.types 中的类
FieldMetadata 的构建器类。
fieldNames() - 类 io.delta.kernel.types.StructType 中的方法
 
fields() - 类 io.delta.kernel.types.StructType 中的方法
 
FileIO - io.delta.kernel.defaults.engine.fileio 中的接口
文件 I/O 操作的接口。
FileReadRequest - io.delta.kernel.engine 中的接口
表示从给定文件读取一定字节范围的请求。
FileSizeHistogramResult - io.delta.kernel.metrics 中的接口
存储文件大小直方图信息以跟踪文件大小分布及其计数。
FileStatus - io.delta.kernel.utils 中的类
用于封装 Delta Lake 表中文件元数据的类。
FileSystemClient - io.delta.kernel.engine 中的接口
为 Delta Kernel 提供文件系统相关功能。
filter(Function<T, Boolean>) - 接口 io.delta.kernel.utils.CloseableIterator 中的方法
返回一个新的 CloseableIterator,其中只包含此迭代器中给定 mapper 函数返回 true 的元素。
FilteredColumnarBatch - io.delta.kernel.data 中的类
表示 ColumnarBatch 的过滤版本。
FilteredColumnarBatch(ColumnarBatch, Optional<ColumnVector>) - 类 io.delta.kernel.data.FilteredColumnarBatch 的构造函数
 
FLOAT - 类 io.delta.kernel.types.FloatType 中的静态变量
 
FloatType - io.delta.kernel.types 中的类
表示 float 类型值的数据类型。
flush() - 类 io.delta.kernel.defaults.engine.hadoopio.HadoopPositionOutputStream 中的方法
 
forEach(Consumer<? super T>) - 接口 io.delta.kernel.utils.CloseableIterable 中的方法
 
forPath(Engine, String) - 接口 io.delta.kernel.Table 中的静态方法
为给定路径的 Delta Lake 表实例化一个表对象。
fromMetadata(FieldMetadata) - 类 io.delta.kernel.types.FieldMetadata.Builder 中的方法
meta.metadata 中的所有元数据添加到构建器的 metadata 中。
fromString(String) - 类 io.delta.kernel.types.CollationIdentifier 中的静态方法
 

G

generateAppendActions(Engine, Row, CloseableIterator<DataFileStatus>, DataWriteContext) - 接口 io.delta.kernel.Transaction 中的静态方法
对于给定的数据文件,生成可在事务中提交的 Delta 操作。
get(String) - 类 io.delta.kernel.types.FieldMetadata 中的方法
 
get(String) - 类 io.delta.kernel.types.StructType 中的方法
 
getAllPrimitiveTypes() - 类 io.delta.kernel.types.BasePrimitiveType 中的静态方法
仅用于测试
getArray(int) - 接口 io.delta.kernel.data.ColumnVector 中的方法
返回位于 rowId 的数组值。
getArray(int) - 接口 io.delta.kernel.data.Row 中的方法
返回位于给定序号的列的数组值。
getBaseSnapshotVersion() - 接口 io.delta.kernel.metrics.TransactionReport 中的方法
创建事务时表的版本。
getBinary(int) - 接口 io.delta.kernel.data.ColumnVector 中的方法
返回 rowId 的二进制类型值。
getBinary(int) - 接口 io.delta.kernel.data.Row 中的方法
返回位于给定序号的列的二进制值。
getBoolean(int) - 接口 io.delta.kernel.data.ColumnVector 中的方法
返回 rowId 的布尔类型值。
getBoolean(int) - 接口 io.delta.kernel.data.Row 中的方法
返回位于给定序号的列的布尔值。
getBoolean(String) - 类 io.delta.kernel.types.FieldMetadata 中的方法
 
getBooleanArray(String) - 类 io.delta.kernel.types.FieldMetadata 中的方法
 
getByte(int) - 接口 io.delta.kernel.data.ColumnVector 中的方法
返回 rowId 的字节类型值。
getByte(int) - 接口 io.delta.kernel.data.Row 中的方法
返回位于给定序号的列的字节值。
getChild(int) - 接口 io.delta.kernel.data.ColumnVector 中的方法
获取与给定序号关联的子向量。
getChildren() - 类 io.delta.kernel.expressions.Column 中的方法
 
getChildren() - 接口 io.delta.kernel.expressions.Expression 中的方法
 
getChildren() - 类 io.delta.kernel.expressions.Literal 中的方法
 
getChildren() - 类 io.delta.kernel.expressions.PartitionValueExpression 中的方法
 
getChildren() - 类 io.delta.kernel.expressions.ScalarExpression 中的方法
 
getCollationIdentifier() - 类 io.delta.kernel.types.StringType 中的方法
 
getColumnVector(int) - 接口 io.delta.kernel.data.ColumnarBatch 中的方法
返回列式批处理中给定序号的 ColumnVector
getCommittedVersion() - 接口 io.delta.kernel.metrics.TransactionReport 中的方法
 
getConf(String) - 接口 io.delta.kernel.defaults.engine.fileio.FileIO 中的方法
获取给定键的配置值。
getConf(String) - 类 io.delta.kernel.defaults.engine.hadoopio.HadoopFileIO 中的方法
 
getData() - 类 io.delta.kernel.data.FilteredColumnarBatch 中的方法
将数据作为 ColumnarBatch 返回。
getDataSkippingFilter() - 接口 io.delta.kernel.metrics.ScanReport 中的方法
 
getDataType() - 接口 io.delta.kernel.data.ColumnVector 中的方法
 
getDataType() - 类 io.delta.kernel.expressions.Literal 中的方法
获取文字对象的数据类型。
getDataType() - 类 io.delta.kernel.expressions.PartitionValueExpression 中的方法
获取分区值的数据类型。
getDataType() - 类 io.delta.kernel.types.StructField 中的方法
 
getDecimal(int) - 接口 io.delta.kernel.data.ColumnVector 中的方法
返回 rowId 的十进制类型值。
getDecimal(int) - 接口 io.delta.kernel.data.Row 中的方法
返回位于给定序号的列的十进制值。
getDescription() - 枚举类 io.delta.kernel.Operation 中的方法
返回将记录在事务日志中的字符串。
getDomainMetadata(String) - 接口 io.delta.kernel.Snapshot 中的方法
如果快照中存在,则返回提供的 domain 的配置。
getDouble(int) - 接口 io.delta.kernel.data.ColumnVector 中的方法
返回 rowId 的双精度类型值。
getDouble(int) - 接口 io.delta.kernel.data.Row 中的方法
返回位于给定序号的列的双精度值。
getDouble(String) - 类 io.delta.kernel.types.FieldMetadata 中的方法
 
getDoubleArray(String) - 类 io.delta.kernel.types.FieldMetadata 中的方法
 
getElementField() - 类 io.delta.kernel.types.ArrayType 中的方法
 
getElements() - 接口 io.delta.kernel.data.ArrayValue 中的方法
一个 ColumnVector,包含恰好 ArrayValue.getSize() 个元素的数组元素。
getElementType() - 类 io.delta.kernel.types.ArrayType 中的方法
 
getEngineInfo() - 接口 io.delta.kernel.metrics.TransactionReport 中的方法
 
getEntries() - 类 io.delta.kernel.types.FieldMetadata 中的方法
 
getEvaluator(StructType, Expression, DataType) - 类 io.delta.kernel.defaults.engine.DefaultExpressionHandler 中的方法
 
getEvaluator(StructType, Expression, DataType) - 接口 io.delta.kernel.engine.ExpressionHandler 中的方法
创建一个 ExpressionEvaluator,它可以在具有给定 batchSchemaColumnarBatch 上评估给定的 expression
getException() - 接口 io.delta.kernel.metrics.DeltaOperationReport 中的方法
 
getExpressionHandler() - 类 io.delta.kernel.defaults.engine.DefaultEngine 中的方法
 
getExpressionHandler() - 接口 io.delta.kernel.engine.Engine 中的方法
获取连接器提供的 ExpressionHandler
getFileCounts() - 接口 io.delta.kernel.metrics.FileSizeHistogramResult 中的方法
getFileStatus(String) - 接口 io.delta.kernel.defaults.engine.fileio.FileIO 中的方法
获取给定路径下文件的元数据。
getFileStatus(String) - 类 io.delta.kernel.defaults.engine.hadoopio.HadoopFileIO 中的方法
 
getFileSystemClient() - 类 io.delta.kernel.defaults.engine.DefaultEngine 中的方法
 
getFileSystemClient() - 接口 io.delta.kernel.engine.Engine 中的方法
获取连接器提供的 FileSystemClient
getFilter() - 接口 io.delta.kernel.metrics.ScanReport 中的方法
 
getFloat(int) - 接口 io.delta.kernel.data.ColumnVector 中的方法
返回 rowId 的浮点类型值。
getFloat(int) - 接口 io.delta.kernel.data.Row 中的方法
返回位于给定序号的列的浮点值。
getInput() - 类 io.delta.kernel.expressions.PartitionValueExpression 中的方法
获取对序列化分区值的表达式引用。
getInt(int) - 接口 io.delta.kernel.data.ColumnVector 中的方法
返回 rowId 的整数类型值。
getInt(int) - 接口 io.delta.kernel.data.Row 中的方法
返回位于给定序号的列的整数值。
getIsFullyConsumed() - 接口 io.delta.kernel.metrics.ScanReport 中的方法
扫描文件迭代器关闭时是否已完全消耗。
getJsonHandler() - 类 io.delta.kernel.defaults.engine.DefaultEngine 中的方法
 
getJsonHandler() - 接口 io.delta.kernel.engine.Engine 中的方法
获取连接器提供的 JsonHandler
getKeyField() - 类 io.delta.kernel.types.MapType 中的方法
 
getKeys() - 接口 io.delta.kernel.data.MapValue 中的方法
包含键的 ColumnVector
getKeyType() - 类 io.delta.kernel.types.MapType 中的方法
 
getLatestSnapshot(Engine) - 接口 io.delta.kernel.Table 中的方法
获取表的最新快照。
getLeft() - 类 io.delta.kernel.expressions.And 中的方法
 
getLeft() - 类 io.delta.kernel.expressions.Or 中的方法
 
getLoadInitialDeltaActionsDurationNs() - 接口 io.delta.kernel.metrics.SnapshotMetricsResult 中的方法
 
getLong(int) - 接口 io.delta.kernel.data.ColumnVector 中的方法
返回 rowId 的长整数类型值。
getLong(int) - 接口 io.delta.kernel.data.Row 中的方法
返回位于给定序号的列的长整数值。
getLong(String) - 类 io.delta.kernel.types.FieldMetadata 中的方法
 
getLongArray(String) - 类 io.delta.kernel.types.FieldMetadata 中的方法
 
getMap(int) - 接口 io.delta.kernel.data.ColumnVector 中的方法
返回位于 rowId 的映射值。
getMap(int) - 接口 io.delta.kernel.data.Row 中的方法
返回位于给定序号的列的映射值。
getMaxValues() - 类 io.delta.kernel.statistics.DataFileStatistics 中的方法
获取数据文件中列的最大值。
getMessage() - 异常 io.delta.kernel.exceptions.TableAlreadyExistsException 中的方法
 
getMetadata() - 类 io.delta.kernel.types.StructField 中的方法
 
getMetadata(String) - 类 io.delta.kernel.types.FieldMetadata.Builder 中的方法
 
getMetadata(String) - 类 io.delta.kernel.types.FieldMetadata 中的方法
 
getMetadataArray(String) - 类 io.delta.kernel.types.FieldMetadata 中的方法
 
getMetricsReporters() - 类 io.delta.kernel.defaults.engine.DefaultEngine 中的方法
 
getMetricsReporters() - 接口 io.delta.kernel.engine.Engine 中的方法
获取引擎的 MetricsReporter 实例以推送报告。
getMinValues() - 类 io.delta.kernel.statistics.DataFileStatistics 中的方法
获取数据文件中列的最小值。
getModificationTime() - 类 io.delta.kernel.utils.FileStatus 中的方法
获取文件的修改时间(以纪元毫秒为单位)。
getName() - 类 io.delta.kernel.expressions.ScalarExpression 中的方法
 
getName() - 类 io.delta.kernel.types.CollationIdentifier 中的方法
 
getName() - 类 io.delta.kernel.types.StructField 中的方法
 
getNames() - 类 io.delta.kernel.expressions.Column 中的方法
 
getNullCount() - 类 io.delta.kernel.statistics.DataFileStatistics 中的方法
获取数据文件中列的空值数量。
getNumActiveAddFiles() - 接口 io.delta.kernel.metrics.ScanMetricsResult 中的方法
 
getNumAddFiles() - 接口 io.delta.kernel.metrics.TransactionMetricsResult 中的方法
 
getNumAddFilesSeen() - 接口 io.delta.kernel.metrics.ScanMetricsResult 中的方法
 
getNumAddFilesSeenFromDeltaFiles() - 接口 io.delta.kernel.metrics.ScanMetricsResult 中的方法
 
getNumCommitAttempts() - 接口 io.delta.kernel.metrics.TransactionMetricsResult 中的方法
 
getNumDuplicateAddFiles() - 接口 io.delta.kernel.metrics.ScanMetricsResult 中的方法
返回日志重放期间遇到的重复 AddFile 操作的数量。
getNumRecords() - 类 io.delta.kernel.statistics.DataFileStatistics 中的方法
获取数据文件中的记录数。
getNumRemoveFiles() - 方法在接口 io.delta.kernel.metrics.TransactionMetricsResult
 
getNumRemoveFilesSeenFromDeltaFiles() - 方法在接口 io.delta.kernel.metrics.ScanMetricsResult
 
getNumTotalActions() - 方法在接口 io.delta.kernel.metrics.TransactionMetricsResult
 
getOperation() - 方法在接口 io.delta.kernel.metrics.TransactionReport
 
getOperationType() - 方法在接口 io.delta.kernel.metrics.DeltaOperationReport
 
getOperationType() - 方法在接口 io.delta.kernel.metrics.ScanReport
 
getOperationType() - 方法在接口 io.delta.kernel.metrics.SnapshotReport
 
getOperationType() - 方法在接口 io.delta.kernel.metrics.TransactionReport
 
getParquetHandler() - 方法在类 io.delta.kernel.defaults.engine.DefaultEngine
 
getParquetHandler() - 方法在接口 io.delta.kernel.engine.Engine
获取连接器提供的 ParquetHandler
getPartitionColumnNames() - 方法在接口 io.delta.kernel.Snapshot
获取此快照中 Delta 表的分区列名。
getPartitionColumns(Engine) - 方法在接口 io.delta.kernel.Transaction
获取分区列的逻辑名称列表。
getPartitionPredicate() - 方法在接口 io.delta.kernel.metrics.ScanReport
 
getPath() - 方法在接口 io.delta.kernel.engine.FileReadRequest
获取要从中读取数据的文件的完全限定路径。
getPath() - 方法在类 io.delta.kernel.utils.FileStatus
获取文件路径。
getPath(Engine) - 方法在接口 io.delta.kernel.Table
Table 实例的完全限定路径。
getPos() - 方法在类 io.delta.kernel.defaults.engine.fileio.PositionOutputStream
获取流中的当前位置。
getPos() - 方法在类 io.delta.kernel.defaults.engine.fileio.SeekableInputStream
获取流中的当前位置。
getPos() - 方法在类 io.delta.kernel.defaults.engine.hadoopio.HadoopPositionOutputStream
 
getPos() - 方法在类 io.delta.kernel.defaults.engine.hadoopio.HadoopSeekableInputStream
 
getPostCommitHooks() - 方法在类 io.delta.kernel.TransactionCommitResult
连接器触发提交后操作。
getPrecision() - 方法在类 io.delta.kernel.types.DecimalType
 
getPredicateEvaluator(StructType, Predicate) - 方法在类 io.delta.kernel.defaults.engine.DefaultExpressionHandler
 
getPredicateEvaluator(StructType, Predicate) - 方法在接口 io.delta.kernel.engine.ExpressionHandler
创建一个 PredicateEvaluator,它可以评估给定的谓词表达式并返回一个选择向量(ColumnVectorboolean 类型)。
getProvidedTimestamp() - 方法在接口 io.delta.kernel.metrics.SnapshotReport
 
getProvider() - 方法在类 io.delta.kernel.types.CollationIdentifier
 
getReadLength() - 方法在接口 io.delta.kernel.engine.FileReadRequest
获取从startOffset开始从文件读取的数据长度。
getReadSchema() - 方法在接口 io.delta.kernel.metrics.ScanReport
 
getReadTableVersion() - 方法在接口 io.delta.kernel.Transaction
获取用作此事务基础的表的最新版本。
getRemainingFilter() - 方法在接口 io.delta.kernel.Scan
获取 Delta Kernel 返回的数据不保证满足的剩余过滤器。
getReportUUID() - 方法在接口 io.delta.kernel.metrics.DeltaOperationReport
 
getRight() - 方法在类 io.delta.kernel.expressions.And
 
getRight() - 方法在类 io.delta.kernel.expressions.Or
 
getRows() - 方法在接口 io.delta.kernel.data.ColumnarBatch
 
getRows() - 方法在类 io.delta.kernel.data.FilteredColumnarBatch
通过过滤器的行迭代器。
getScale() - 方法在类 io.delta.kernel.types.DecimalType
 
getScanBuilder() - 方法在接口 io.delta.kernel.Snapshot
创建一个扫描构建器以构建 Scan,从该快照读取数据。
getScanFiles(Engine) - 方法在接口 io.delta.kernel.Scan
获取要扫描的数据文件的迭代器。
getScanMetrics() - 方法在接口 io.delta.kernel.metrics.ScanReport
 
getScanState(Engine) - 方法在接口 io.delta.kernel.Scan
获取与当前扫描关联的扫描状态。
getSchema() - 方法在接口 io.delta.kernel.data.ColumnarBatch
 
getSchema() - 方法在接口 io.delta.kernel.data.Row
 
getSchema() - 方法在接口 io.delta.kernel.Snapshot
获取此快照中表的模式。
getSchema(Engine) - 方法在接口 io.delta.kernel.Transaction
获取表的模式。
getSelectionVector() - 方法在类 io.delta.kernel.data.FilteredColumnarBatch
可选的选择向量,其中包含数据中每行的条目,指示行是否被选中。
getShort(int) - 方法在接口 io.delta.kernel.data.ColumnVector
返回 rowId 的 short 类型值。
getShort(int) - 方法在接口 io.delta.kernel.data.Row
返回位于给定序号的列的 short 值。
getSize() - 方法在接口 io.delta.kernel.data.ArrayValue
数组中的元素数量
getSize() - 方法在接口 io.delta.kernel.data.ColumnarBatch
 
getSize() - 方法在接口 io.delta.kernel.data.ColumnVector
 
getSize() - 方法在接口 io.delta.kernel.data.MapValue
映射中的元素数量
getSize() - 方法在类 io.delta.kernel.utils.FileStatus
获取文件大小(字节)。
getSnapshotAsOfTimestamp(Engine, long) - 方法在接口 io.delta.kernel.Table
获取指定 timestamp 处表的快照。
getSnapshotAsOfVersion(Engine, long) - 方法在接口 io.delta.kernel.Table
获取指定 versionId 处的快照。
getSnapshotMetrics() - 方法在接口 io.delta.kernel.metrics.SnapshotReport
 
getSnapshotReportUUID() - 方法在接口 io.delta.kernel.metrics.ScanReport
 
getSnapshotReportUUID() - 方法在接口 io.delta.kernel.metrics.TransactionReport
 
getSortedBinBoundaries() - 方法在接口 io.delta.kernel.metrics.FileSizeHistogramResult
排序的 bin 边界列表,其中每个元素表示 bin 的开始(包含)和下一个元素表示 bin 的结束(不包含)。
getStartOffset() - 方法在接口 io.delta.kernel.engine.FileReadRequest
获取文件中开始读取数据的起始偏移量。
getStatistics() - 方法在类 io.delta.kernel.utils.DataFileStatus
获取此对象中封装的数据文件的统计信息。
getStatisticsColumns() - 方法在接口 io.delta.kernel.DataWriteContext
返回连接器可以选择性收集统计信息的 Column 列表。
getString(int) - 方法在接口 io.delta.kernel.data.ColumnVector
返回 rowId 的字符串类型值。
getString(int) - 方法在接口 io.delta.kernel.data.Row
返回位于给定序号的列的字符串值。
getString(String) - 方法在类 io.delta.kernel.types.FieldMetadata
 
getStringArray(String) - 方法在类 io.delta.kernel.types.FieldMetadata
 
getStruct(int) - 方法在接口 io.delta.kernel.data.Row
返回位于给定序号的列的结构值。
getTableFileSizeHistogram() - 方法在接口 io.delta.kernel.metrics.TransactionMetricsResult
 
getTablePath() - 方法在异常 io.delta.kernel.exceptions.TableNotFoundException
 
getTablePath() - 方法在接口 io.delta.kernel.metrics.DeltaOperationReport
 
getTableSchema() - 方法在接口 io.delta.kernel.metrics.ScanReport
 
getTableVersion() - 方法在接口 io.delta.kernel.metrics.ScanReport
 
getTargetDirectory() - 方法在接口 io.delta.kernel.DataWriteContext
返回数据应写入的目标目录。
getTimestamp(Engine) - 方法在接口 io.delta.kernel.Snapshot
获取此快照中最新提交的时间戳(自 Unix 纪元以来的毫秒数)。
getTimestampToVersionResolutionDurationNs() - 方法在接口 io.delta.kernel.metrics.SnapshotMetricsResult
 
getTotalAddFilesSizeInBytes() - 方法在接口 io.delta.kernel.metrics.TransactionMetricsResult
 
getTotalBytes() - 方法在接口 io.delta.kernel.metrics.FileSizeHistogramResult
FileSizeHistogramResult.getSortedBinBoundaries() 的每个 bin 中的总字节数
getTotalCommitDurationNs() - 方法在接口 io.delta.kernel.metrics.TransactionMetricsResult
 
getTotalPlanningDurationNs() - 方法在接口 io.delta.kernel.metrics.ScanMetricsResult
返回查找、过滤和消耗扫描文件的总持续时间。
getTotalRemoveFilesSizeInBytes() - 方法在接口 io.delta.kernel.metrics.TransactionMetricsResult
 
getTransactionMetrics() - 方法在接口 io.delta.kernel.metrics.TransactionReport
 
getTransactionMetrics() - 方法在类 io.delta.kernel.TransactionCommitResult
 
getTransactionState(Engine) - 方法在接口 io.delta.kernel.Transaction
获取事务状态。
getType() - 方法在接口 io.delta.kernel.hook.PostCommitHook
 
getValue() - 方法在类 io.delta.kernel.expressions.Literal
获取字面值。
getValueField() - 方法在类 io.delta.kernel.types.MapType
 
getValues() - 方法在接口 io.delta.kernel.data.MapValue
包含值的 ColumnVector
getValueType() - 方法在类 io.delta.kernel.types.MapType
 
getVersion() - 方法在接口 io.delta.kernel.metrics.SnapshotReport
对于按版本时间旅行查询,这是提供的版本。
getVersion() - 方法在接口 io.delta.kernel.Snapshot
获取表中此快照的版本。
getVersion() - 方法在类 io.delta.kernel.TransactionCommitResult
包含作为提交事务的版本。
getVersion() - 方法在类 io.delta.kernel.types.CollationIdentifier
 
getWriteContext(Engine, Row, Map<String, Literal>) - 接口 io.delta.kernel.Transaction 中的静态方法
获取将数据写入表的上下文。

H

HadoopFileIO - 类在 io.delta.kernel.defaults.engine.hadoopio
基于 Hadoop API 的 FileIO 实现。
HadoopFileIO(Configuration) - 类 io.delta.kernel.defaults.engine.hadoopio.HadoopFileIO 的构造器
 
HadoopInputFile - 类在 io.delta.kernel.defaults.engine.hadoopio
 
HadoopInputFile(FileSystem, Path, long) - 类 io.delta.kernel.defaults.engine.hadoopio.HadoopInputFile 的构造器
 
HadoopOutputFile - 类在 io.delta.kernel.defaults.engine.hadoopio
 
HadoopOutputFile(Configuration, String) - 类 io.delta.kernel.defaults.engine.hadoopio.HadoopOutputFile 的构造器
 
HadoopPositionOutputStream - 类在 io.delta.kernel.defaults.engine.hadoopio
 
HadoopPositionOutputStream(FSDataOutputStream) - 类 io.delta.kernel.defaults.engine.hadoopio.HadoopPositionOutputStream 的构造器
 
HadoopSeekableInputStream - 类在 io.delta.kernel.defaults.engine.hadoopio
 
HadoopSeekableInputStream(FSDataInputStream) - 类 io.delta.kernel.defaults.engine.hadoopio.HadoopSeekableInputStream 的构造器
 
hashCode() - 方法在类 io.delta.kernel.expressions.Column
 
hashCode() - 方法在类 io.delta.kernel.statistics.DataFileStatistics
 
hashCode() - 方法在类 io.delta.kernel.types.ArrayType
 
hashCode() - 方法在类 io.delta.kernel.types.BasePrimitiveType
 
hashCode() - 方法在类 io.delta.kernel.types.DataType
 
hashCode() - 方法在类 io.delta.kernel.types.DecimalType
 
hashCode() - 方法在类 io.delta.kernel.types.FieldMetadata
 
hashCode() - 方法在类 io.delta.kernel.types.MapType
 
hashCode() - 方法在类 io.delta.kernel.types.StructField
 
hashCode() - 方法在类 io.delta.kernel.types.StructType
 
hashCode() - 方法在类 io.delta.kernel.utils.FileStatus
 
hasNext() - 方法在接口 io.delta.kernel.utils.CloseableIterator
如果迭代有更多元素,则返回 true。

I

INCLUDE - 枚举类 io.delta.kernel.utils.CloseableIterator.BreakableFilterResult 中的枚举常量
表示当前元素应包含在 CloseableIterator.breakableFilter(Function) 产生的结果迭代器中。
indexOf(String) - 方法在类 io.delta.kernel.types.StructType
 
inMemoryIterable(CloseableIterator<T>) - 接口 io.delta.kernel.utils.CloseableIterable 中的静态方法
返回一个 CloseableIterable 对象,该对象由给定 CloseableIterator 的内存中集合支持。
InputFile - 接口在 io.delta.kernel.defaults.engine.fileio
用于读取文件并获取其元数据的接口。
INTEGER - 类 io.delta.kernel.types.IntegerType 中的静态变量
 
IntegerType - 类在 io.delta.kernel.types
表示 integer 类型值的数据类型。
InvalidConfigurationValueException - 异常在 io.delta.kernel.exceptions
当为表属性指定非法值时抛出此异常。
InvalidConfigurationValueException(String, String, String) - 异常 io.delta.kernel.exceptions.InvalidConfigurationValueException 的构造器
 
InvalidTableException - io.delta.kernel.exceptions 中的异常
当遇到无效表时抛出;表的日志和/或检查点文件处于无效状态。
InvalidTableException(String, String) - 异常 io.delta.kernel.exceptions.InvalidTableException 的构造器
 
io.delta.kernel - 包 io.delta.kernel
Delta Kernel 接口,用于构建表示 Delta Lake 表的表对象,从表中获取快照,以及构建扫描对象以扫描表中数据的子集。
io.delta.kernel.annotation - 包 io.delta.kernel.annotation
 
io.delta.kernel.data - 包 io.delta.kernel.data
Delta Kernel 接口,用于表示列式和行式数据。
io.delta.kernel.defaults.engine - 包 io.delta.kernel.defaults.engine
Engine 接口及其由 Engine 公开的子接口的默认实现。
io.delta.kernel.defaults.engine.fileio - 包 io.delta.kernel.defaults.engine.fileio
 
io.delta.kernel.defaults.engine.hadoopio - 包 io.delta.kernel.defaults.engine.hadoopio
 
io.delta.kernel.engine - 包 io.delta.kernel.engine
接口,允许连接器提供他们自己的函数实现,例如读取 Parquet 文件、列出文件系统中的文件、解析 JSON 字符串等。
io.delta.kernel.exceptions - 包 io.delta.kernel.exceptions
 
io.delta.kernel.expressions - 包 io.delta.kernel.expressions
表达式框架,定义了连接器可用于将谓词传递给 Delta Kernel 的最常见表达式。
io.delta.kernel.hook - 包 io.delta.kernel.hook
 
io.delta.kernel.metrics - 包 io.delta.kernel.metrics
 
io.delta.kernel.statistics - 包 io.delta.kernel.statistics
 
io.delta.kernel.types - 包 io.delta.kernel.types
Delta Kernel 定义的数据类型,用于在 Delta Kernel 和连接器之间交换类型信息。
io.delta.kernel.utils - 包 io.delta.kernel.utils
实用工具。
isDataColumn() - 类 io.delta.kernel.types.StructField 中的方法
 
isMetadataColumn() - 类 io.delta.kernel.types.StructField 中的方法
 
isNullable() - 类 io.delta.kernel.types.StructField 中的方法
 
isNullAt(int) - 接口 io.delta.kernel.data.ColumnVector 中的方法
 
isNullAt(int) - 接口 io.delta.kernel.data.Row 中的方法
 
isPrimitiveType(String) - 类 io.delta.kernel.types.BasePrimitiveType 中的静态方法
给定类型名称是否为原始类型?
isValueContainsNull() - 类 io.delta.kernel.types.MapType 中的方法
 
iterator() - 接口 io.delta.kernel.utils.CloseableIterable 中的方法
重写默认的迭代器方法以返回一个 CloseableIterator

J

JsonHandler - io.delta.kernel.engine 中的接口
为 Delta Kernel 提供 JSON 处理功能。

K

KernelEngineException - io.delta.kernel.exceptions 中的异常
Engine 在执行操作时遇到错误时抛出。
KernelEngineException(String, Throwable) - 异常 io.delta.kernel.exceptions.KernelEngineException 的构造器
 
KernelException - io.delta.kernel.exceptions 中的异常
当 Kernel 由于操作无效或不受支持而无法执行请求的操作时抛出。
KernelException() - 异常 io.delta.kernel.exceptions.KernelException 的构造器
 
KernelException(String) - 异常 io.delta.kernel.exceptions.KernelException 的构造器
 
KernelException(String, Throwable) - 异常 io.delta.kernel.exceptions.KernelException 的构造器
 
KernelException(Throwable) - 异常 io.delta.kernel.exceptions.KernelException 的构造器
 

L

length() - 接口 io.delta.kernel.defaults.engine.fileio.InputFile 中的方法
获取文件大小。
length() - 类 io.delta.kernel.defaults.engine.hadoopio.HadoopInputFile 中的方法
 
length() - 类 io.delta.kernel.types.StructType 中的方法
 
listFrom(String) - 类 io.delta.kernel.defaults.engine.DefaultFileSystemClient 中的方法
 
listFrom(String) - 接口 io.delta.kernel.defaults.engine.fileio.FileIO 中的方法
列出同一目录中按字典顺序(UTF-8 排序)大于或等于给定 `path` 的路径。
listFrom(String) - 类 io.delta.kernel.defaults.engine.hadoopio.HadoopFileIO 中的方法
 
listFrom(String) - 接口 io.delta.kernel.engine.FileSystemClient 中的方法
列出同一目录中按字典顺序(UTF-8 排序)大于或等于给定 `path` 的路径。
Literal - io.delta.kernel.expressions 中的类
一个字面值。
LOG_COMPACTION - 枚举类 io.delta.kernel.hook.PostCommitHook.PostCommitHookType 中的枚举常量
写入一个日志压缩文件,该文件将一系列提交 JSON 文件合并为一个文件。
LoggingMetricsReporter - io.delta.kernel.defaults.engine 中的类
一个 MetricsReporter 的实现,它将报告(以 JSON 格式)记录到 Log4J 的 info 级别。
LoggingMetricsReporter() - 类 io.delta.kernel.defaults.engine.LoggingMetricsReporter 的构造器
 
LONG - 类 io.delta.kernel.types.LongType 中的静态变量
 
LongType - io.delta.kernel.types 中的类
表示 long 类型值的数据类型。

M

MANUAL_UPDATE - 枚举类 io.delta.kernel.Operation 中的枚举常量
适用于任何不符合上述类别的操作。
map(Function<T, U>) - 接口 io.delta.kernel.utils.CloseableIterator 中的方法
 
MapType - io.delta.kernel.types 中的类
表示 map 类型的数据类型。
MapType(DataType, DataType, boolean) - 类 io.delta.kernel.types.MapType 的构造器
 
MapType(StructField, StructField) - 类 io.delta.kernel.types.MapType 的构造器
 
MapValue - io.delta.kernel.data 中的接口
表示 ColumnVector 中单个映射值的抽象。
METADATA_ROW_INDEX_COLUMN - 类 io.delta.kernel.types.StructField 中的静态变量
 
METADATA_ROW_INDEX_COLUMN_NAME - 类 io.delta.kernel.types.StructField 中的静态变量
行索引元数据列的名称。
MetadataChangedException - io.delta.kernel.exceptions 中的异常
当 Delta 表的元数据在事务开始和提交之间发生更改时抛出。
MetadataChangedException() - 异常 io.delta.kernel.exceptions.MetadataChangedException 的构造器
 
MetricsReport - io.delta.kernel.metrics 中的接口
包含给定操作指标的接口
MetricsReporter - io.delta.kernel.engine 中的接口
用于向 Delta 表报告操作指标的接口
MICROSECONDS_PER_SECOND - 类 io.delta.kernel.statistics.DataFileStatistics 中的静态变量
 
mkdirs(String) - 类 io.delta.kernel.defaults.engine.DefaultFileSystemClient 中的方法
 
mkdirs(String) - 接口 io.delta.kernel.defaults.engine.fileio.FileIO 中的方法
在给定路径创建目录,包括父目录。
mkdirs(String) - 类 io.delta.kernel.defaults.engine.hadoopio.HadoopFileIO 中的方法
 
mkdirs(String) - 接口 io.delta.kernel.engine.FileSystemClient 中的方法
在给定路径创建目录,包括父目录。

N

NANOSECONDS_PER_MICROSECOND - 类 io.delta.kernel.statistics.DataFileStatistics 中的静态变量
 
newInputFile(String, long) - 接口 io.delta.kernel.defaults.engine.fileio.FileIO 中的方法
获取一个 InputFile,用于读取给定路径的文件,可以从文件中的任意位置读取。
newInputFile(String, long) - 类 io.delta.kernel.defaults.engine.hadoopio.HadoopFileIO 中的方法
 
newOutputFile(String) - 接口 io.delta.kernel.defaults.engine.fileio.FileIO 中的方法
创建 OutputFile,用于在给定路径下写入新文件。
newOutputFile(String) - 类 io.delta.kernel.defaults.engine.hadoopio.HadoopFileIO 中的方法
 
newStream() - 接口 io.delta.kernel.defaults.engine.fileio.InputFile 中的方法
获取用于读取文件的输入流。
newStream() - 类 io.delta.kernel.defaults.engine.hadoopio.HadoopInputFile 中的方法
 
next() - 接口 io.delta.kernel.utils.CloseableIterator 中的方法
返回迭代中的下一个元素。

O

of(String) - 类 io.delta.kernel.utils.FileStatus 中的静态方法
创建一个 FileStatus,其中包含给定路径,大小和修改时间均设置为 0。
of(String, long, long) - 类 io.delta.kernel.utils.FileStatus 中的静态方法
创建一个 FileStatus,其中包含给定路径、大小和修改时间。
ofBinary(byte[]) - 类 io.delta.kernel.expressions.Literal 中的静态方法
创建一个 binary 类型字面量表达式。
ofBoolean(boolean) - 类 io.delta.kernel.expressions.Literal 中的静态方法
创建一个 boolean 类型字面量表达式。
ofByte(byte) - 类 io.delta.kernel.expressions.Literal 中的静态方法
创建一个 byte 类型字面量表达式。
ofDate(int) - 类 io.delta.kernel.expressions.Literal 中的静态方法
创建一个 date 类型字面量表达式。
ofDecimal(BigDecimal, int, int) - 类 io.delta.kernel.expressions.Literal 中的静态方法
创建一个 decimal 类型字面量表达式。
ofDouble(double) - 类 io.delta.kernel.expressions.Literal 中的静态方法
创建一个 double 类型字面量表达式。
ofFloat(float) - 类 io.delta.kernel.expressions.Literal 中的静态方法
创建一个 float 类型字面量表达式。
ofInt(int) - 类 io.delta.kernel.expressions.Literal 中的静态方法
创建一个 integer 类型字面量表达式。
ofLong(long) - 类 io.delta.kernel.expressions.Literal 中的静态方法
创建一个 long 类型字面量表达式。
ofNull(DataType) - 类 io.delta.kernel.expressions.Literal 中的静态方法
创建 null 值字面量。
ofShort(short) - 类 io.delta.kernel.expressions.Literal 中的静态方法
创建一个 short 类型字面量表达式。
ofString(String) - 类 io.delta.kernel.expressions.Literal 中的静态方法
创建一个 string 类型字面量表达式。
ofTimestamp(long) - 类 io.delta.kernel.expressions.Literal 中的静态方法
创建一个 timestamp 类型字面量表达式。
ofTimestampNtz(long) - 类 io.delta.kernel.expressions.Literal 中的静态方法
创建一个 timestamp_ntz 类型字面量表达式。
Operation - io.delta.kernel 中的枚举类
可以在 Delta 表上执行的操作。
Or - io.delta.kernel.expressions 中的类
OR 表达式
Or(Predicate, Predicate) - 类 io.delta.kernel.expressions.Or 的构造器
 
OutputFile - io.delta.kernel.defaults.engine.fileio 中的接口
用于写入文件并获取其元数据的接口。

P

ParquetHandler - io.delta.kernel.engine 中的接口
为 Delta Kernel 提供 Parquet 文件相关功能。
parseJson(ColumnVector, StructType, Optional<ColumnVector>) - 类 io.delta.kernel.defaults.engine.DefaultJsonHandler 中的方法
 
parseJson(ColumnVector, StructType, Optional<ColumnVector>) - 接口 io.delta.kernel.engine.JsonHandler 中的方法
解析给定的 json 字符串,并以 ColumnarBatch 中的列形式返回 outputSchema 请求的字段。
partitionExists(Engine, Snapshot, Predicate) - 类 io.delta.kernel.utils.PartitionUtils 中的静态方法
检查分区是否存在(即。
PartitionUtils - io.delta.kernel.utils 中的类
 
PartitionValueExpression - io.delta.kernel.expressions 中的类
根据 Delta 协议规范 将序列化分区值解码为分区类型值的表达式。
PartitionValueExpression(Expression, DataType) - 类 io.delta.kernel.expressions.PartitionValueExpression 的构造器
创建 partition_value 表达式。
path() - 接口 io.delta.kernel.defaults.engine.fileio.InputFile 中的方法
获取文件的路径。
path() - 接口 io.delta.kernel.defaults.engine.fileio.OutputFile 中的方法
获取文件的路径。
path() - 类 io.delta.kernel.defaults.engine.hadoopio.HadoopInputFile 中的方法
 
path() - 类 io.delta.kernel.defaults.engine.hadoopio.HadoopOutputFile 中的方法
 
PositionOutputStream - io.delta.kernel.defaults.engine.fileio 中的类
扩展 OutputStream 以提供流中的当前位置。
PositionOutputStream() - 类 io.delta.kernel.defaults.engine.fileio.PositionOutputStream 的构造器
 
PostCommitHook - io.delta.kernel.hook 中的接口
在事务提交后执行操作的钩子。
PostCommitHook.PostCommitHookType - io.delta.kernel.hook 中的枚举类
 
Predicate - io.delta.kernel.expressions 中的类
定义谓词标量表达式,它是 ScalarExpression 的扩展,对于每个输入行,它评估为 true、false 或 null。
Predicate(String, Expression) - 类 io.delta.kernel.expressions.Predicate 的一元谓词表达式构造器
一元谓词表达式的构造器
Predicate(String, Expression, Expression) - 类 io.delta.kernel.expressions.Predicate 的二元谓词表达式构造器
二元谓词表达式的构造器
Predicate(String, List<Expression>) - 类 io.delta.kernel.expressions.Predicate 的构造器
 
PredicateEvaluator - io.delta.kernel.expressions 中的接口
用于评估输入批处理上的 Predicate 的特殊接口,并返回一个选择向量,其中包含输入批处理中每行的值,指示该行是否通过谓词。
ProtocolChangedException - io.delta.kernel.exceptions 中的异常
当 Delta 表的协议在事务开始时间和提交时间之间发生变化时抛出。
ProtocolChangedException(long) - 异常 io.delta.kernel.exceptions.ProtocolChangedException 的构造器
 
putBoolean(String, boolean) - 类 io.delta.kernel.types.FieldMetadata.Builder 中的方法
 
putBooleanArray(String, Boolean[]) - 类 io.delta.kernel.types.FieldMetadata.Builder 中的方法
 
putDouble(String, double) - 类 io.delta.kernel.types.FieldMetadata.Builder 中的方法
 
putDoubleArray(String, Double[]) - 类 io.delta.kernel.types.FieldMetadata.Builder 中的方法
 
putFieldMetadata(String, FieldMetadata) - 类 io.delta.kernel.types.FieldMetadata.Builder 中的方法
 
putFieldMetadataArray(String, FieldMetadata[]) - 类 io.delta.kernel.types.FieldMetadata.Builder 中的方法
 
putLong(String, long) - 类 io.delta.kernel.types.FieldMetadata.Builder 中的方法
 
putLongArray(String, Long[]) - 类 io.delta.kernel.types.FieldMetadata.Builder 中的方法
 
putNull(String) - 方法在类 io.delta.kernel.types.FieldMetadata.Builder
 
putString(String, String) - 方法在类 io.delta.kernel.types.FieldMetadata.Builder
 
putStringArray(String, String[]) - 方法在类 io.delta.kernel.types.FieldMetadata.Builder
 

R

read() - 方法在类 io.delta.kernel.defaults.engine.hadoopio.HadoopSeekableInputStream
 
read(byte[]) - 方法在类 io.delta.kernel.defaults.engine.hadoopio.HadoopSeekableInputStream
 
read(byte[], int, int) - 方法在类 io.delta.kernel.defaults.engine.hadoopio.HadoopSeekableInputStream
 
readFiles(CloseableIterator<FileReadRequest>) - 方法在类 io.delta.kernel.defaults.engine.DefaultFileSystemClient
 
readFiles(CloseableIterator<FileReadRequest>) - 方法在接口 io.delta.kernel.engine.FileSystemClient
返回一个字节流迭代器,readRequests 中的每个读取请求对应一个字节流。
readFully(byte[], int, int) - 方法在类 io.delta.kernel.defaults.engine.fileio.SeekableInputStream
将缓冲区 b 中完全读取 len 字节。
readFully(byte[], int, int) - 方法在类 io.delta.kernel.defaults.engine.hadoopio.HadoopSeekableInputStream
 
readJsonFiles(CloseableIterator<FileStatus>, StructType, Optional<Predicate>) - 方法在类 io.delta.kernel.defaults.engine.DefaultJsonHandler
 
readJsonFiles(CloseableIterator<FileStatus>, StructType, Optional<Predicate>) - 方法在接口 io.delta.kernel.engine.JsonHandler
读取并解析给定位置的 JSON 格式文件,并将数据作为 ColumnarBatch 返回,其中包含 physicalSchema 请求的列。
readParquetFiles(CloseableIterator<FileStatus>, StructType, Optional<Predicate>) - 方法在类 io.delta.kernel.defaults.engine.DefaultParquetHandler
 
readParquetFiles(CloseableIterator<FileStatus>, StructType, Optional<Predicate>) - 方法在接口 io.delta.kernel.engine.ParquetHandler
读取给定位置的 Parquet 格式文件,并将数据作为 ColumnarBatch 返回,其中包含 physicalSchema 请求的列。
removeDomainMetadata(String) - 方法在接口 io.delta.kernel.Transaction
在此事务中将具有标识符 domain 的域元数据标记为已删除。
REPLACE_TABLE - 枚举常量在枚举类 io.delta.kernel.Operation
在 REPLACE 操作期间记录(也可视为覆盖)
report(MetricsReport) - 方法在类 io.delta.kernel.defaults.engine.LoggingMetricsReporter
 
report(MetricsReport) - 方法在接口 io.delta.kernel.engine.MetricsReporter
通过报告 MetricsReport 来指示操作已完成
resolvePath(String) - 方法在类 io.delta.kernel.defaults.engine.DefaultFileSystemClient
 
resolvePath(String) - 方法在接口 io.delta.kernel.defaults.engine.fileio.FileIO
将给定路径解析为完全限定路径。
resolvePath(String) - 方法在类 io.delta.kernel.defaults.engine.hadoopio.HadoopFileIO
 
resolvePath(String) - 方法在接口 io.delta.kernel.engine.FileSystemClient
将给定路径解析为完全限定路径。
Row - 接口在 io.delta.kernel.data
表示单条记录

S

ScalarExpression - 类在 io.delta.kernel.expressions
标量 SQL 表达式,接受零个或多个输入,并为每个输入行生成一个输出值。
ScalarExpression(String, List<Expression>) - 类 io.delta.kernel.expressions.ScalarExpression 的构造函数
 
Scan - 接口在 io.delta.kernel
表示对 Delta 表的扫描。
ScanBuilder - 接口在 io.delta.kernel
用于构建 Scan 对象的构建器。
ScanMetricsResult - 接口在 io.delta.kernel.metrics
存储 ScanReport 的指标结果
ScanReport - 接口在 io.delta.kernel.metrics
定义 Scan MetricsReport 的元数据和指标
seek(long) - 方法在类 io.delta.kernel.defaults.engine.fileio.SeekableInputStream
定位到流中的新位置。
seek(long) - 方法在类 io.delta.kernel.defaults.engine.hadoopio.HadoopSeekableInputStream
 
SeekableInputStream - 类在 io.delta.kernel.defaults.engine.fileio
扩展 InputStream 以提供流中的当前位置并寻找到新位置。
SeekableInputStream() - 类 io.delta.kernel.defaults.engine.fileio.SeekableInputStream 的构造函数
 
serializeAsJson(StructType) - 方法在类 io.delta.kernel.statistics.DataFileStatistics
将统计信息序列化为 JSON 字符串。
SHORT - 静态变量在类 io.delta.kernel.types.ShortType
 
ShortType - 类在 io.delta.kernel.types
表示 short 类型值的数据类型。
skip(long) - 方法在类 io.delta.kernel.defaults.engine.hadoopio.HadoopSeekableInputStream
 
Snapshot - 接口在 io.delta.kernel
表示 Delta 表的快照。
SnapshotMetricsResult - 接口在 io.delta.kernel.metrics
存储 SnapshotReport 的指标结果
SnapshotReport - 接口在 io.delta.kernel.metrics
定义快照构建 MetricsReport 的元数据和指标
spliterator() - 方法在接口 io.delta.kernel.utils.CloseableIterable
 
STREAMING_UPDATE - 枚举常量在枚举类 io.delta.kernel.Operation
在流式插入期间记录。
STRING - 静态变量在类 io.delta.kernel.types.StringType
 
StringType - 类在 io.delta.kernel.types
表示 string 类型值的数据类型。
StringType(CollationIdentifier) - 类 io.delta.kernel.types.StringType 的构造函数
 
StringType(String) - 类 io.delta.kernel.types.StringType 的构造函数
 
StructField - 类在 io.delta.kernel.types
表示 StructType 的子字段,具有附加属性和元数据。
StructField(String, DataType, boolean) - 类 io.delta.kernel.types.StructField 的构造函数
 
StructField(String, DataType, boolean, FieldMetadata) - 类 io.delta.kernel.types.StructField 的构造函数
 
StructType - 类在 io.delta.kernel.types
包含一个或多个列的结构体类型。
StructType() - 类 io.delta.kernel.types.StructType 的构造函数
 
StructType(List<StructField>) - 类 io.delta.kernel.types.StructType 的构造函数
 

T

Table - 接口在 io.delta.kernel
表示给定路径的 Delta Lake 表。
TableAlreadyExistsException - 异常在 io.delta.kernel.exceptions
尝试在已存在 Delta 表的位置创建 Delta 表时抛出此异常。
TableAlreadyExistsException(String) - 异常 io.delta.kernel.exceptions.TableAlreadyExistsException 的构造函数
 
TableAlreadyExistsException(String, String) - 异常 io.delta.kernel.exceptions.TableAlreadyExistsException 的构造函数
 
TableNotFoundException - 异常在 io.delta.kernel.exceptions
当给定位置没有 Delta 表时抛出。
TableNotFoundException(String) - 异常 io.delta.kernel.exceptions.TableNotFoundException 的构造函数
 
TableNotFoundException(String, String) - 异常 io.delta.kernel.exceptions.TableNotFoundException 的构造函数
 
takeWhile(Function<T, Boolean>) - 方法在接口 io.delta.kernel.utils.CloseableIterator
返回一个新的 CloseableIterator,只要给定的 mapper 函数返回 true,就包含来自此迭代器的元素。
threadSafeInvoke(Engine) - 方法在接口 io.delta.kernel.hook.PostCommitHook
调用提交后操作,其实现必须是线程安全的。
TIMESTAMP - 静态变量在类 io.delta.kernel.types.TimestampType
 
TIMESTAMP_NTZ - 静态变量在类 io.delta.kernel.types.TimestampNTZType
 
TimestampNTZType - 类在 io.delta.kernel.types
不带时区的时间戳类型表示微秒精度的本地时间,与时区无关。
TimestampType - 类在 io.delta.kernel.types
时间戳类型,支持 [0001-01-01T00:00:00.000000Z, 9999-12-31T23:59:59.999999Z],其中左/右边界是 UTC+00:00 中原始儒略历的日期和时间。
toInMemoryList() - 方法在接口 io.delta.kernel.utils.CloseableIterator
将此 CloseableIterator 中的所有元素收集到一个 List 中。
toJson() - 方法在类 io.delta.kernel.types.StructType
将结构类型转换为 Delta 协议指定的序列化格式。
toString() - 方法在类 io.delta.kernel.expressions.Column
 
toString() - 方法在类 io.delta.kernel.expressions.Literal
 
toString() - 方法在类 io.delta.kernel.expressions.PartitionValueExpression
 
toString() - 方法在类 io.delta.kernel.expressions.Predicate
 
toString() - 方法在类 io.delta.kernel.expressions.ScalarExpression
 
toString() - 方法在类 io.delta.kernel.statistics.DataFileStatistics
 
toString() - 方法在类 io.delta.kernel.types.ArrayType
 
toString() - 方法在类 io.delta.kernel.types.BasePrimitiveType
 
toString() - 方法在类 io.delta.kernel.types.CollationIdentifier
 
toString() - 方法在类 io.delta.kernel.types.DataType
 
toString() - 方法在类 io.delta.kernel.types.DecimalType
 
toString() - 方法在类 io.delta.kernel.types.FieldMetadata
 
toString() - 方法在类 io.delta.kernel.types.MapType
 
toString() - 方法在类 io.delta.kernel.types.StructField
 
toString() - 方法在类 io.delta.kernel.types.StructType
 
toString() - 方法在类 io.delta.kernel.utils.DataFileStatus
 
toString() - 方法在类 io.delta.kernel.utils.FileStatus
 
toStringWithoutVersion() - 方法在类 io.delta.kernel.types.CollationIdentifier
 
Transaction - 接口在 io.delta.kernel
表示修改 Delta 表的事务。
TransactionBuilder - 接口在 io.delta.kernel
用于创建 Transaction 以修改 Delta 表的构建器。
TransactionCommitResult - 类在 io.delta.kernel
包含成功事务提交的结果。
TransactionCommitResult(long, List<PostCommitHook>, TransactionMetricsResult) - 类 io.delta.kernel.TransactionCommitResult 的构造函数
 
TransactionMetricsResult - 接口在 io.delta.kernel.metrics
存储 TransactionReport 的指标结果
TransactionReport - 接口在 io.delta.kernel.metrics
定义事务的元数据和指标 MetricsReport
transformLogicalData(Engine, Row, CloseableIterator<FilteredColumnarBatch>, Map<String, Literal>) - 静态方法在接口 io.delta.kernel.Transaction
给定需要写入表的逻辑数据,根据表的 Delta 协议和表上启用的功能,将其转换为所需的物理数据。
transformPhysicalData(Engine, Row, Row, CloseableIterator<ColumnarBatch>) - 静态方法在接口 io.delta.kernel.Scan
将从表数据文件读取的物理数据转换为 Delta 表中预期的逻辑数据。

U

UnknownConfigurationException - 异常在 io.delta.kernel.exceptions
指定未知配置键时抛出。
UnknownConfigurationException(String) - 异常 io.delta.kernel.exceptions.UnknownConfigurationException 的构造函数
 
USER_DEFAULT - 静态变量在类 io.delta.kernel.types.DecimalType
 

V

valueOf(String) - 静态方法在枚举类 io.delta.kernel.hook.PostCommitHook.PostCommitHookType
返回此类的具有指定名称的枚举常量。
valueOf(String) - 静态方法在枚举类 io.delta.kernel.Operation
返回此类的具有指定名称的枚举常量。
valueOf(String) - 静态方法在枚举类 io.delta.kernel.utils.CloseableIterator.BreakableFilterResult
返回此类的具有指定名称的枚举常量。
values() - 静态方法在枚举类 io.delta.kernel.hook.PostCommitHook.PostCommitHookType
返回一个数组,其中包含此枚举类的常量,按其声明的顺序排列。
values() - 静态方法在枚举类 io.delta.kernel.Operation
返回一个数组,其中包含此枚举类的常量,按其声明的顺序排列。
values() - 静态方法在枚举类 io.delta.kernel.utils.CloseableIterator.BreakableFilterResult
返回一个数组,其中包含此枚举类的常量,按其声明的顺序排列。
VARIANT - 静态变量在类 io.delta.kernel.types.VariantType
 
VariantType - 类在 io.delta.kernel.types
一种逻辑变体类型。

W

withClusteringColumns(Engine, List<Column>) - 方法在接口 io.delta.kernel.TransactionBuilder
在创建新的集群表时设置集群列的列表。
withDeletedColumnAt(int) - 方法在接口 io.delta.kernel.data.ColumnarBatch
返回此 ColumnarBatch 的副本,其中删除了给定 ordinal 处的列。
withDomainMetadataSupported() - 方法在接口 io.delta.kernel.TransactionBuilder
如果尚未支持域元数据,则在此表上启用对域元数据的支持。
withFilter(Predicate) - 方法在接口 io.delta.kernel.ScanBuilder
应用给定的过滤器表达式,以修剪任何可能不包含满足给定过滤器的数据的文件。
withLogCompactionInverval(int) - 方法在接口 io.delta.kernel.TransactionBuilder
设置日志压缩之间的提交次数。
withMaxRetries(int) - 方法在接口 io.delta.kernel.TransactionBuilder
设置在检测到并发写入时重试事务的最大次数。
withNewColumn(int, StructField, ColumnVector) - 方法在接口 io.delta.kernel.data.ColumnarBatch
返回 ColumnarBatch 的副本,其中在给定 ordinal 处插入了给定 columnVector
withNewMetadata(FieldMetadata) - 方法在类 io.delta.kernel.types.StructField
 
withNewSchema(StructType) - 方法在接口 io.delta.kernel.data.ColumnarBatch
生成此 ColumnarBatch 的副本,其中包含给定的 newSchema
withPartitionColumns(Engine, List<String>) - 方法在接口 io.delta.kernel.TransactionBuilder
在创建新的分区表时设置分区列的列表。
withReadSchema(StructType) - 方法在接口 io.delta.kernel.ScanBuilder
应用给定的 readSchema
withSchema(Engine, StructType) - 接口 io.delta.kernel.TransactionBuilder 中的方法
设置表的模式。
withTableProperties(Engine, Map<String, String>) - 接口 io.delta.kernel.TransactionBuilder 中的方法
设置表的表属性。
withTablePropertiesRemoved(Set<String>) - 接口 io.delta.kernel.TransactionBuilder 中的方法
取消设置表中提供的表属性。
withTransactionId(Engine, String, long) - 接口 io.delta.kernel.TransactionBuilder 中的方法
为幂等写入设置事务标识符。
write(byte[]) - 类 io.delta.kernel.defaults.engine.hadoopio.HadoopPositionOutputStream 中的方法
 
write(byte[], int, int) - 类 io.delta.kernel.defaults.engine.hadoopio.HadoopPositionOutputStream 中的方法
 
write(int) - 类 io.delta.kernel.defaults.engine.hadoopio.HadoopPositionOutputStream 中的方法
 
WRITE - 枚举类 io.delta.kernel.Operation 中的枚举常量
在批量插入期间记录。
writeAtomically(CloseableIterator<String>, boolean) - 接口 io.delta.kernel.defaults.engine.fileio.OutputFile 中的方法
原子性写入(要么完全写入,要么完全不写入 - 即
writeAtomically(CloseableIterator<String>, boolean) - 类 io.delta.kernel.defaults.engine.hadoopio.HadoopOutputFile 中的方法
 
writeJsonFileAtomically(String, CloseableIterator<Row>, boolean) - 类 io.delta.kernel.defaults.engine.DefaultJsonHandler 中的方法
利用 `delta-storage` 中的 LogStore 实现,根据目标文件系统原子性地将数据写入文件。
writeJsonFileAtomically(String, CloseableIterator<Row>, boolean) - 接口 io.delta.kernel.engine.JsonHandler 中的方法
将迭代器中的每个 Row 序列化为 JSON,并作为单独的行写入目标文件。
writeParquetFileAtomically(String, CloseableIterator<FilteredColumnarBatch>) - 类 io.delta.kernel.defaults.engine.DefaultParquetHandler 中的方法
利用 `delta-storage` 中的 LogStore 实现,根据目标文件系统原子性地将数据写入文件。
writeParquetFileAtomically(String, CloseableIterator<FilteredColumnarBatch>) - 接口 io.delta.kernel.engine.ParquetHandler 中的方法
将给定数据写入为 Parquet 文件。
writeParquetFiles(String, CloseableIterator<FilteredColumnarBatch>, List<Column>) - 类 io.delta.kernel.defaults.engine.DefaultParquetHandler 中的方法
 
writeParquetFiles(String, CloseableIterator<FilteredColumnarBatch>, List<Column>) - 接口 io.delta.kernel.engine.ParquetHandler 中的方法
将给定数据批次写入 Parquet 文件。
A B C D E F G H I J K L M N O P R S T U V W 
所有类和接口|所有包|常量字段值|序列化形式