首页
/ Apache Arrow DataFusion参数类型推断测试的优化实践

Apache Arrow DataFusion参数类型推断测试的优化实践

2025-06-14 08:00:27作者:裴麒琰

在Apache Arrow DataFusion项目中,参数类型推断是一个重要功能,它允许SQL查询中的参数(如$1)在运行时被替换为具体的值。然而,现有的测试代码存在大量重复,这给代码维护和测试覆盖率的评估带来了挑战。

现有测试的问题

当前测试实现存在以下主要问题:

  1. 每个测试用例都重复了创建逻辑计划、验证参数类型、替换参数值等相同流程
  2. 测试断言分散,难以一目了然地看到完整的测试场景
  3. 测试输出格式不一致,增加了维护成本
  4. 难以快速识别哪些边界情况尚未被覆盖

解决方案设计

我们设计了一个ParameterTest结构体来封装测试逻辑:

struct ParameterTest {
    sql: &'static str,  // 测试SQL语句
    expected_types: Vec<(&'static str, Option<DataType>)>,  // 预期参数类型
    param_values: Vec<ScalarValue>,  // 参数值
}

该结构体提供了run方法,封装了以下测试步骤:

  1. 解析SQL生成逻辑计划
  2. 验证参数类型推断结果
  3. 用提供的参数值替换查询中的参数
  4. 生成包含初始计划和最终计划的格式化输出

改进后的测试示例

改进后的测试用例更加简洁明了:

#[test]
fn test_infer_types_from_predicate() {
    let test = ParameterTest {
      sql: "SELECT id, age FROM person WHERE age = $1",
      expected_types: vec![("$1", Some(DataType::Int32))],
      param_values: vec![ScalarValue::Int32(Some(10))],
    };
 
    assert_snapshot!(test.run(), @r#"
 ** Initial Plan:
    Projection: person.id, person.age
      Filter: person.age = $1
        TableScan: person
 ** Final Plan:
    Projection: person.id, person.age
      Filter: person.age = Int32(10)
        TableScan: person
    "#);
}

技术优势

  1. 一致性:所有测试遵循相同模式,便于理解和维护
  2. 可读性:测试意图更加清晰,减少了样板代码
  3. 可维护性:修改测试逻辑只需调整ParameterTest实现
  4. 可扩展性:易于添加新的验证点或测试维度
  5. 覆盖率可视化:可以轻松统计所有测试用例的参数类型组合

实现细节

在ParameterTest的实现中,我们特别注意了:

  1. 错误处理的统一性,确保测试失败时能提供有意义的错误信息
  2. 快照测试(insta)的集成,便于验证计划变更
  3. 类型系统的充分利用,减少运行时错误
  4. 测试输出的格式化,便于人工审查

总结

通过引入ParameterTest结构体,我们显著提升了DataFusion参数类型推断测试的可维护性和可读性。这种模式也可以推广到项目中的其他测试场景,如表达式测试、优化规则测试等,进一步提升整个项目的测试质量。

这种测试结构的改进不仅减少了代码重复,更重要的是建立了一套标准化的测试模式,使得新贡献者能够更快地理解和添加测试用例,从而促进项目的可持续发展。

登录后查看全文

项目优选

收起
kernelkernel
openEuler内核是openEuler操作系统的核心,既是系统性能与稳定性的基石,也是连接处理器、设备与服务的桥梁。
C
471
466
kernelkernel
deepin linux kernel
C
32
16
atomcodeatomcode
Claude Code 的开源替代方案。连接任意大模型,编辑代码,运行命令,自动验证 — 全自动执行。用 Rust 构建,极致性能。 | An open-source alternative to Claude Code. Connect any LLM, edit code, run commands, and verify changes — autonomously. Built in Rust for speed. Get Started
Rust
2.09 K
218
ops-nnops-nn
本项目是CANN提供的神经网络类计算算子库,实现网络在NPU上加速计算。
C++
700
1.4 K
docsdocs
暂无描述
Dockerfile
780
5.08 K
pytorchpytorch
Ascend Extension for PyTorch
Python
758
968
flutter_flutterflutter_flutter
本仓库是 Flutter SDK 与 Flutter Engine 的 OpenHarmony 适配版本,由 CPF-Flutter 团队维护。开发者可使用熟悉的 Flutter 技术栈开发 OpenHarmony 应用,3.35.7 及以后的适配版本可基于本仓库源码构建支持 OpenHarmony 的 Flutter Engine。
Dart
1.04 K
271
ops-transformerops-transformer
本项目是CANN提供的transformer类大模型算子库,实现网络在NPU上加速计算。
C++
880
2.03 K
mindquantummindquantum
MindQuantum is a general software library supporting the development of applications for quantum computation.
Python
183
112
openHiTLSopenHiTLS
旨在打造算法先进、性能卓越、高效敏捷、安全可靠的密码套件,通过轻量级、可剪裁的软件技术架构满足各行业不同场景的多样化要求,让密码技术应用更简单,同时探索后量子等先进算法创新实践,构建密码前沿技术底座!
C
1.11 K
682