首页
/ 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
511
551
docsdocs
暂无描述
Markdown
854
5.69 K
ops-transformerops-transformer
本项目是CANN提供的transformer类大模型算子库,实现网络在NPU上加速计算。
C++
1.05 K
2.5 K
kernelkernel
deepin linux kernel
C
33
16
pytorchpytorch
作为 Ascend for PyTorch 社区的核心组件,TorchNPU 是昇腾专为 PyTorch 打造的深度学习适配插件,使 PyTorch 框架能够直接调用昇腾 NPU,为开发者提供昇腾 AI 处理器的超强算力。
Python
840
1.28 K
ops-nnops-nn
本项目是CANN提供的神经网络类计算算子库,实现网络在NPU上加速计算。
C++
848
1.71 K
ops-mathops-math
本项目是CANN提供的数学类基础计算算子库,实现网络在NPU上加速计算。
C++
1.25 K
1.38 K
jiuwenswarmjiuwenswarm
JiuwenSwarm 是一款基于openJiuwen开发的智能AI Agent,它能够将大语言模型的强大能力,通过你日常使用的各类通讯应用,直接延伸至你的指尖。
Python
3.34 K
859
AscendNPU-IRAscendNPU-IR
AscendNPU-IR是基于MLIR(Multi-Level Intermediate Representation)构建的,面向昇腾亲和算子编译时使用的中间表示,提供昇腾完备表达能力,通过编译优化提升昇腾AI处理器计算效率,支持通过生态框架使能昇腾AI处理器与深度调优
C++
511
347
cann-learning-hubcann-learning-hub
CANN 学习中心仓,支持在线互动运行、边学边练,提供教程、示例与优化方案,一站式助力昇腾开发者快速上手。
Jupyter Notebook
789
414