16935267080

Committed 13 Aug 2025 11:00AM UTC coverage: 24.312% (-63.3%) from 87.658%

Build # 16935267080

Build Type

Pull #4226

github

Committed by

web-flow

Commit Message

Merge 81b48c7fb into baa6ea202

Pull Request Pull Request #4226: Support converting TimestampTZ to and from duckdb

Run Details

0 of 2 new or added lines in 1 file covered. (0.0%)

20666 existing lines in 469 files now uncovered.

8726 of 35892 relevant lines covered (24.31%)

147.74 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

0.0

/encodings/sparse/src/compute/binary_numeric.rs

// SPDX-License-Identifier: Apache-2.0
// SPDX-FileCopyrightText: Copyright the Vortex contributors

use vortex_array::arrays::ConstantArray;
use vortex_array::compute::{NumericKernel, NumericKernelAdapter, numeric};
use vortex_array::{Array, ArrayRef, IntoArray, register_kernel};
use vortex_error::{VortexResult, vortex_err};
use vortex_scalar::NumericOperator;

use crate::{SparseArray, SparseVTable};

impl NumericKernel for SparseVTable {
    fn numeric(
        &self,
        array: &SparseArray,
        rhs: &dyn Array,
        op: NumericOperator,
    ) -> VortexResult<Option<ArrayRef>> {
        let Some(rhs_scalar) = rhs.as_constant() else {
            return Ok(None);
        };

        let new_patches = array.patches().clone().map_values(|values| {
            let rhs_const_array = ConstantArray::new(rhs_scalar.clone(), values.len()).into_array();

            numeric(&values, &rhs_const_array, op)
        })?;
        let new_fill_value = array
            .fill_scalar()
            .as_primitive()
            .checked_binary_numeric(&rhs_scalar.as_primitive(), op)
            .ok_or_else(|| vortex_err!("numeric overflow"))?
            .into();
        Ok(Some(
            SparseArray::try_new_from_patches(new_patches, new_fill_value)?.into_array(),
        ))
    }
}

register_kernel!(NumericKernelAdapter(SparseVTable).lift());

1	// SPDX-License-Identifier: Apache-2.0
2	// SPDX-FileCopyrightText: Copyright the Vortex contributors
3
4	use vortex_array::arrays::ConstantArray;
5	use vortex_array::compute::{NumericKernel, NumericKernelAdapter, numeric};
6	use vortex_array::{Array, ArrayRef, IntoArray, register_kernel};
7	use vortex_error::{VortexResult, vortex_err};
8	use vortex_scalar::NumericOperator;
9
10	use crate::{SparseArray, SparseVTable};
11
12	impl NumericKernel for SparseVTable {
UNCOV 13	fn numeric(	×
UNCOV 14	&self,	×
UNCOV 15	array: &SparseArray,	×
UNCOV 16	rhs: &dyn Array,	×
UNCOV 17	op: NumericOperator,	×
UNCOV 18	) -> VortexResult<Option<ArrayRef>> {	×
UNCOV 19	let Some(rhs_scalar) = rhs.as_constant() else {	×
20	return Ok(None);	×
21	};
22
UNCOV 23	let new_patches = array.patches().clone().map_values(\|values\| {	×
UNCOV 24	let rhs_const_array = ConstantArray::new(rhs_scalar.clone(), values.len()).into_array();	×
25
UNCOV 26	numeric(&values, &rhs_const_array, op)	×
UNCOV 27	})?;	×
UNCOV 28	let new_fill_value = array	×
UNCOV 29	.fill_scalar()	×
UNCOV 30	.as_primitive()	×
UNCOV 31	.checked_binary_numeric(&rhs_scalar.as_primitive(), op)	×
UNCOV 32	.ok_or_else(\|\| vortex_err!("numeric overflow"))?	×
UNCOV 33	.into();	×
34	Ok(Some(
UNCOV 35	SparseArray::try_new_from_patches(new_patches, new_fill_value)?.into_array(),	×
36	))
UNCOV 37	}	×
38	}
39
40	register_kernel!(NumericKernelAdapter(SparseVTable).lift());

vortex-data / vortex / 16935267080

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous