无法将ChunkedArray::chunks返回的引用转为具体Arrow类型的问题

问题出在类型不匹配：你尝试将ChunkedArray的chunk向下转换为PrimitiveArray<i64>，但实际上ChunkedArray<Int64Type>中的chunk类型是PrimitiveArray<Int64Type>，而非PrimitiveArray<i64>。这两个是Rust中的不同类型，所以downcast_ref会返回None。

具体解释 #

arrow2中，ChunkedArray<T>的内部chunk是与类型参数T绑定的PrimitiveArray<T>，这里的Int64Type是封装了i64的类型标记，它和直接的i64是不同的Rust类型——尽管它们对应的Arrow物理类型都是Int64。

而你在working_conversion中直接创建的是PrimitiveArray<i64>，所以向下转换到这个类型能成功。

修正后的代码 #

修改from_chunked_wtf中的downcast目标类型为PrimitiveArray<Int64Type>即可：

fn from_chunked_wtf() {
    let a: ChunkedArray<Int64Type> = ChunkedArray::from_vec("a", vec![1,2,3]);
    let c1 = a.chunks().first().unwrap();
    print_ref_type_name(&**c1);
    // 修正目标类型为PrimitiveArray<Int64Type>
    let b = (&(**c1)).as_any().downcast_ref::<PrimitiveArray<Int64Type>>();
    println!("arrow type: {:?}", &(**c1).data_type().to_physical_type());
    print_type_name(b);
    println!("fixed: {:?}", b);
}

运行后会得到预期的Some(Int64[1, 2, 3])结果。

额外提示 #

如果你需要获取底层的i64缓冲区，可以通过PrimitiveArray<Int64Type>的values()方法直接访问：

if let Some(prim_array) = b {
    let buffer = prim_array.values();
    println!("raw buffer: {:?}", buffer);
}

内容的提问来源于stack exchange，提问作者ExpandingMan