16970635821

Committed 14 Aug 2025 04:13PM UTC coverage: 85.882% (-1.8%) from 87.693%

Build # 16970635821

Build Type

Pull #4215

github

Committed by

web-flow

Commit Message

Merge 5182504a6 into f547cbca5

Pull Request Pull Request #4215: Ji/vectors

Run Details

80 of 1729 new or added lines in 38 files covered. (4.63%)

117 existing lines in 25 files now uncovered.

56994 of 66363 relevant lines covered (85.88%)

609331.7 hits per line

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

0.0

/vortex-array/src/pipeline/query/operators.rs

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

use vortex_error::{VortexExpect, VortexResult};

use crate::pipeline::Kernel;
use crate::pipeline::operators::BindContext;
use crate::pipeline::query::Pipeline;
use crate::pipeline::query::buffers::VectorAllocationPlan;
use crate::pipeline::query::dag::DagNode;
use crate::pipeline::vector::VectorId;

impl Pipeline<'_> {
    pub(in crate::pipeline) fn bind_operators(
        dag: &[DagNode],
        allocation_plan: &VectorAllocationPlan,
    ) -> VortexResult<Vec<Box<dyn Kernel>>> {
        let mut operators = Vec::with_capacity(dag.len());
        for node in dag {
            let input_ids = node
                .children
                .iter()
                .map(|node_idx| {
                    allocation_plan.output_targets[*node_idx]
                        .vector_id()
                        .vortex_expect("Input node must have an output vector ID")
                })
                .collect::<Vec<_>>();
            let bind_context = PipelineBindContext {
                children: input_ids,
            };
            let operator = node.plan_node.bind(&bind_context)?;
            operators.push(operator);
        }
        Ok(operators)
    }
}

struct PipelineBindContext {
    children: Vec<VectorId>,
}

impl BindContext for PipelineBindContext {
    fn children(&self) -> &[VectorId] {
        &self.children
    }
}

1	// SPDX-License-Identifier: Apache-2.0
2	// SPDX-FileCopyrightText: Copyright the Vortex contributors
3
4	use vortex_error::{VortexExpect, VortexResult};
5
6	use crate::pipeline::Kernel;
7	use crate::pipeline::operators::BindContext;
8	use crate::pipeline::query::Pipeline;
9	use crate::pipeline::query::buffers::VectorAllocationPlan;
10	use crate::pipeline::query::dag::DagNode;
11	use crate::pipeline::vector::VectorId;
12
13	impl Pipeline<'_> {
NEW 14	pub(in crate::pipeline) fn bind_operators(	×
NEW 15	dag: &[DagNode],	×
NEW 16	allocation_plan: &VectorAllocationPlan,	×
NEW 17	) -> VortexResult<Vec<Box<dyn Kernel>>> {	×
NEW 18	let mut operators = Vec::with_capacity(dag.len());	×
NEW 19	for node in dag {	×
NEW 20	let input_ids = node	×
NEW 21	.children	×
NEW 22	.iter()	×
NEW 23	.map(\|node_idx\| {	×
NEW 24	allocation_plan.output_targets[*node_idx]	×
NEW 25	.vector_id()	×
NEW 26	.vortex_expect("Input node must have an output vector ID")	×
NEW 27	})	×
NEW 28	.collect::<Vec<_>>();	×
NEW 29	let bind_context = PipelineBindContext {	×
NEW 30	children: input_ids,	×
NEW 31	};	×
NEW 32	let operator = node.plan_node.bind(&bind_context)?;	×
NEW 33	operators.push(operator);	×
34	}
NEW 35	Ok(operators)	×
NEW 36	}	×
37	}
38
39	struct PipelineBindContext {
40	children: Vec<VectorId>,
41	}
42
43	impl BindContext for PipelineBindContext {
NEW 44	fn children(&self) -> &[VectorId] {	×
NEW 45	&self.children	×
NEW 46	}	×
47	}

vortex-data / vortex / 16970635821

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