16991469020

Committed 15 Aug 2025 01:54PM UTC coverage: 86.018% (-1.8%) from 87.855%

Build # 16991469020

Build Type

Pull #4215

github

Committed by

web-flow

Commit Message

Merge 58201b202 into 62e231a41

Pull Request Pull Request #4215: Ji/vectors

Run Details

90 of 1746 new or added lines in 40 files covered. (5.15%)

117 existing lines in 25 files now uncovered.

56661 of 65871 relevant lines covered (86.02%)

614266.74 hits per line

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

0.0

/vortex-expr/src/operator/mod.rs

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

mod reduce;

use std::sync::Arc;

pub use reduce::*;
use vortex_array::pipeline::operators::Operator;
use vortex_array::{Array, ArrayRef};
use vortex_error::{VortexResult, vortex_err};

use crate::traversal::{FoldUp, NodeFolder};
use crate::{ExprRef, RootVTable};

pub struct ExprOperatorConverter {
    root: ArrayRef,
}

impl ExprOperatorConverter {
    pub fn new(root: ArrayRef) -> Self {
        Self { root }
    }
}

// Needs a mapping from Root array to encoding -> Operator

impl NodeFolder for ExprOperatorConverter {
    type NodeTy = ExprRef;
    type Result = Arc<dyn Operator>;

    fn visit_up(
        &mut self,
        node: ExprRef,
        children: Vec<Arc<dyn Operator>>,
    ) -> VortexResult<FoldUp<Arc<dyn Operator>>> {
        if node.as_opt::<RootVTable>().is_some() {
            let pipeline = self.root.to_pipeline_plan()?;
            return Ok(FoldUp::Continue(pipeline));
        }
        node.operator(children)
            .ok_or_else(|| vortex_err!("Failed to convert operator: {:?}", node))
            .map(FoldUp::Continue)
    }
}

1	// SPDX-License-Identifier: Apache-2.0
2	// SPDX-FileCopyrightText: Copyright the Vortex contributors
3
4	mod reduce;
5
6	use std::sync::Arc;
7
8	pub use reduce::*;
9	use vortex_array::pipeline::operators::Operator;
10	use vortex_array::{Array, ArrayRef};
11	use vortex_error::{VortexResult, vortex_err};
12
13	use crate::traversal::{FoldUp, NodeFolder};
14	use crate::{ExprRef, RootVTable};
15
16	pub struct ExprOperatorConverter {
17	root: ArrayRef,
18	}
19
20	impl ExprOperatorConverter {
NEW 21	pub fn new(root: ArrayRef) -> Self {	×
NEW 22	Self { root }	×
NEW 23	}	×
24	}
25
26	// Needs a mapping from Root array to encoding -> Operator
27
28	impl NodeFolder for ExprOperatorConverter {
29	type NodeTy = ExprRef;
30	type Result = Arc<dyn Operator>;
31
NEW 32	fn visit_up(	×
NEW 33	&mut self,	×
NEW 34	node: ExprRef,	×
NEW 35	children: Vec<Arc<dyn Operator>>,	×
NEW 36	) -> VortexResult<FoldUp<Arc<dyn Operator>>> {	×
NEW 37	if node.as_opt::<RootVTable>().is_some() {	×
NEW 38	let pipeline = self.root.to_pipeline_plan()?;	×
NEW 39	return Ok(FoldUp::Continue(pipeline));	×
NEW 40	}	×
NEW 41	node.operator(children)	×
NEW 42	.ok_or_else(\|\| vortex_err!("Failed to convert operator: {:?}", node))	×
NEW 43	.map(FoldUp::Continue)	×
NEW 44	}	×
45	}

vortex-data / vortex / 16991469020

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