vortex_array/arrays/varbin/compute/
cast.rs

1// SPDX-License-Identifier: Apache-2.0
2// SPDX-FileCopyrightText: Copyright the Vortex contributors
3
4use vortex_dtype::DType;
5use vortex_error::VortexResult;
6
7use crate::arrays::{VarBinArray, VarBinVTable};
8use crate::compute::{CastKernel, CastKernelAdapter};
9use crate::vtable::ValidityHelper;
10use crate::{ArrayRef, IntoArray, register_kernel};
11
12impl CastKernel for VarBinVTable {
13    fn cast(&self, array: &VarBinArray, dtype: &DType) -> VortexResult<Option<ArrayRef>> {
14        if !array.dtype().eq_ignore_nullability(dtype) {
15            return Ok(None);
16        }
17
18        let new_nullability = dtype.nullability();
19        let new_validity = array.validity().clone().cast_nullability(new_nullability)?;
20        let new_dtype = array.dtype().with_nullability(new_nullability);
21        Ok(Some(
22            VarBinArray::try_new(
23                array.offsets().clone(),
24                array.bytes().clone(),
25                new_dtype,
26                new_validity,
27            )?
28            .into_array(),
29        ))
30    }
31}
32
33register_kernel!(CastKernelAdapter(VarBinVTable).lift());
34
35#[cfg(test)]
36mod tests {
37    use rstest::rstest;
38    use vortex_dtype::{DType, Nullability};
39
40    use crate::arrays::VarBinArray;
41    use crate::compute::cast;
42
43    #[rstest]
44    #[case(
45        DType::Utf8(Nullability::Nullable),
46        DType::Utf8(Nullability::NonNullable)
47    )]
48    #[case(
49        DType::Binary(Nullability::Nullable),
50        DType::Binary(Nullability::NonNullable)
51    )]
52    #[case(
53        DType::Utf8(Nullability::NonNullable),
54        DType::Utf8(Nullability::Nullable)
55    )]
56    #[case(
57        DType::Binary(Nullability::NonNullable),
58        DType::Binary(Nullability::Nullable)
59    )]
60    fn try_cast_varbin_nullable(#[case] source: DType, #[case] target: DType) {
61        let varbin = VarBinArray::from_iter(vec![Some("a"), Some("b"), Some("c")], source);
62
63        let res = cast(varbin.as_ref(), &target);
64        assert_eq!(res.unwrap().dtype(), &target);
65    }
66
67    #[rstest]
68    #[should_panic]
69    #[case(DType::Utf8(Nullability::Nullable))]
70    #[should_panic]
71    #[case(DType::Binary(Nullability::Nullable))]
72    fn try_cast_varbin_fail(#[case] source: DType) {
73        let non_nullable_source = source.as_nonnullable();
74        let varbin = VarBinArray::from_iter(vec![Some("a"), Some("b"), None], source);
75        cast(varbin.as_ref(), &non_nullable_source).unwrap();
76    }
77}
vortex_array/arrays/varbin/compute/cast.rs

vortex_array/arrays/varbin/compute/
cast.rs
