16387130526

Committed 19 Jul 2025 09:05AM UTC coverage: 81.512% (-0.008%) from 81.52%

Build # 16387130526

Build Type

push

github

Committed by

web-flow

Commit Message

feat: duckdb workstealing (#3927)

Signed-off-by: Alexander Droste <alexander.droste@protonmail.com>

Run Details

16 of 17 new or added lines in 1 file covered. (94.12%)

185 existing lines in 8 files now uncovered.

42000 of 51526 relevant lines covered (81.51%)

171508.11 hits per line

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

92.31

/vortex-array/src/arrays/varbinview/ops.rs

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

use vortex_error::VortexResult;
use vortex_scalar::Scalar;

use crate::arrays::{VarBinViewArray, VarBinViewVTable, varbin_scalar};
use crate::vtable::{OperationsVTable, ValidityHelper};
use crate::{ArrayRef, IntoArray};

impl OperationsVTable<VarBinViewVTable> for VarBinViewVTable {
    fn slice(array: &VarBinViewArray, start: usize, stop: usize) -> VortexResult<ArrayRef> {
        let views = array.views().slice(start..stop);

        Ok(VarBinViewArray::try_new(
            views,
            array.buffers().to_vec(),
            array.dtype().clone(),
            array.validity().slice(start, stop)?,
        )?
        .into_array())
    }

    fn scalar_at(array: &VarBinViewArray, index: usize) -> VortexResult<Scalar> {
        Ok(varbin_scalar(array.bytes_at(index), array.dtype()))
    }
}

1	// SPDX-License-Identifier: Apache-2.0
2	// SPDX-FileCopyrightText: Copyright the Vortex contributors
3
4	use vortex_error::VortexResult;
5	use vortex_scalar::Scalar;
6
7	use crate::arrays::{VarBinViewArray, VarBinViewVTable, varbin_scalar};
8	use crate::vtable::{OperationsVTable, ValidityHelper};
9	use crate::{ArrayRef, IntoArray};
10
11	impl OperationsVTable<VarBinViewVTable> for VarBinViewVTable {
12	fn slice(array: &VarBinViewArray, start: usize, stop: usize) -> VortexResult<ArrayRef> {	5,909✔
13	let views = array.views().slice(start..stop);	5,909✔
14
15	Ok(VarBinViewArray::try_new(	5,909✔
16	views,	5,909✔
17	array.buffers().to_vec(),	5,909✔
18	array.dtype().clone(),	5,909✔
19	array.validity().slice(start, stop)?,	5,909✔
UNCOV 20	)?	×
21	.into_array())	5,909✔
22	}	5,909✔
23
24	fn scalar_at(array: &VarBinViewArray, index: usize) -> VortexResult<Scalar> {	1,636✔
25	Ok(varbin_scalar(array.bytes_at(index), array.dtype()))	1,636✔
26	}	1,636✔
27	}

vortex-data / vortex / 16387130526

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