索引
所有类和接口|所有包|常量字段值|序列化形式
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 中
-
表示在
CloseableIterator
的CloseableIterator.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 中的方法
- 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
,它可以在具有给定 batchSchema 的ColumnarBatch
上评估给定的 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 中的方法
-
FileSizeHistogramResult.getSortedBinBoundaries()
中每个 bin 的文件总数 - 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 中
- 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
- 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 中
- 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 中
- 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 文件。
所有类和接口|所有包|常量字段值|序列化形式