本教程详细阐述了如何使用 delta standalone 库高效地扫描 delta 表中的特定数据。通过构建复杂的谓词表达式对分区列进行过滤，并利用 delta standalone 的内部迭代器 `closeableparquetdataiterator`，直接将过滤后的文件元数据转换为 `rowrecord` 记录，从而避免全表扫描，实现对目标数据的精确提取。文章将提供详细的代码示例，并强调使用内部 api 的注意事项。
Delta Standalone 数据扫描概述
Delta Standalone 是一个轻量级库，允许用户直接读取 Delta Lake 表的数据，而无需完整的 Spark 环境。在处理大型 Delta 表时，如果需要验证或检索符合特定条件的数据，执行全表扫描是不可取的，因为它会导致显著的性能开销和资源浪费。Delta Standalone 提供了 `DeltaLog.snapshot().scan()` 方法，允许用户通过指定谓词（predicate）来过滤数据文件，从而实现高效的数据检索。
`scan()` 方法的核心思想是利用 Delta 表的事务日志和元数据，首先识别出与给定谓词匹配的数据文件。这个过程主要作用于分区列，因为分区信息通常直接体现在文件路径中，可以快速进行剪枝。对于非分区列的过滤，`scan()` 还会返回一个“剩余谓词”（residual predicate），这部分过滤通常需要在读取文件内容后在内存中进行。
构建扫描谓词表达式
`scan()` 方法接受一个 `Expression` 对象作为参数，用于定义数据过滤条件。Delta Standalone 提供了多种表达式类型，如 `EqualTo`、`And`、`Or`、`Column`、`Literal` 等，可以组合起来构建复杂的过滤逻辑。
单个分区列过滤
要过滤单个分区列，可以使用 `EqualTo` 表达式。例如，过滤 `partitioned_col_1` 等于 `partition_val_1` 的数据：
import io.delta.standalone.expressions.Column
import io.delta.standalone.expressions.EqualTo
import io.delta.standalone.expressions.Literal
import io.delta.standalone.types.StringType
val predicate = EqualTo(
Column("partitioned_col_1", StringType()),
Literal.of("partition_val_1")
)
多个分区列组合过滤
当需要同时满足多个条件时，可以使用 `And` 表达式将它们组合起来。`scan()` 方法只接受一个 `Expression`，因此所有条件都必须封装在一个根表达式中。
import io.delta.standalone.expressions.And
import io.delta.standalone.expressions.Column
import io.delta.standalone.expressions.EqualTo
import io.delta.standalone.expressions.Literal
import io.delta.standalone.types.StringType
// 定义第一个条件
val condition1 = EqualTo(
Column("partitioned_col_1", StringType()),
Literal.of("partition_val_1")
)
// 定义第二个条件
val condition2 = EqualTo(
Column("partitioned_col_2", StringType()),
Literal.of("partition_val_2")
)
// 定义第三个条件
val condition3 = EqualTo(
Column("partitioned_col_3", StringType()),
Literal.of("partition_val_3")
)
// 使用 And 组合所有条件。And 表达式通常接受两个参数，所以需要嵌套。
val combinedPredicate = And(condition1, And(condition2, condition3))
// 如果有更多条件，可以继续嵌套或使用集合的 reduce 操作：
// val predicates = listOf(condition1, condition2, condition3, condition4)
// val combinedPredicate = predicates.reduce { acc, expr -> And(acc, expr) }
