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/traversal/operator.rs

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

use std::sync::Arc;

use itertools::Itertools;
use pipeline::operators::Operator;
use vortex_array::pipeline;
use vortex_error::VortexResult;

use crate::traversal::{Node, NodeContainer, Transformed, TraversalOrder};

impl<'a> NodeContainer<'a, Self> for Arc<dyn Operator> {
    fn apply_elements<F: FnMut(&'a Self) -> VortexResult<TraversalOrder>>(
        &'a self,
        mut f: F,
    ) -> VortexResult<TraversalOrder> {
        f(self)
    }

    fn map_elements<F: FnMut(Self) -> VortexResult<Transformed<Self>>>(
        self,
        mut f: F,
    ) -> VortexResult<Transformed<Self>> {
        f(self)
    }
}

impl Node for Arc<dyn Operator> {
    fn apply_children<'a, F: FnMut(&'a Self) -> VortexResult<TraversalOrder>>(
        &'a self,
        _f: F,
    ) -> VortexResult<TraversalOrder> {
        todo!()
    }

    fn map_children<F: FnMut(Self) -> VortexResult<Transformed<Self>>>(
        self,
        f: F,
    ) -> VortexResult<Transformed<Self>> {
        let transformed = self
            .children()
            .iter()
            .cloned()
            .collect_vec()
            .map_elements(f)?;

        if transformed.changed {
            Ok(Transformed {
                value: self.with_children(transformed.value),
                order: transformed.order,
                changed: true,
            })
        } else {
            Ok(Transformed::no(self))
        }
    }

    fn iter_children<T>(&self, f: impl FnOnce(&mut dyn Iterator<Item = &Self>) -> T) -> T {
        f(&mut self.children().iter())
    }

    fn children_count(&self) -> usize {
        self.children().len()
    }
}

1	// SPDX-License-Identifier: Apache-2.0
2	// SPDX-FileCopyrightText: Copyright the Vortex contributors
3
4	use std::sync::Arc;
5
6	use itertools::Itertools;
7	use pipeline::operators::Operator;
8	use vortex_array::pipeline;
9	use vortex_error::VortexResult;
10
11	use crate::traversal::{Node, NodeContainer, Transformed, TraversalOrder};
12
13	impl<'a> NodeContainer<'a, Self> for Arc<dyn Operator> {
NEW 14	fn apply_elements<F: FnMut(&'a Self) -> VortexResult<TraversalOrder>>(	×
NEW 15	&'a self,	×
NEW 16	mut f: F,	×
NEW 17	) -> VortexResult<TraversalOrder> {	×
NEW 18	f(self)	×
NEW 19	}	×
20
NEW 21	fn map_elements<F: FnMut(Self) -> VortexResult<Transformed<Self>>>(	×
NEW 22	self,	×
NEW 23	mut f: F,	×
NEW 24	) -> VortexResult<Transformed<Self>> {	×
NEW 25	f(self)	×
NEW 26	}	×
27	}
28
29	impl Node for Arc<dyn Operator> {
NEW 30	fn apply_children<'a, F: FnMut(&'a Self) -> VortexResult<TraversalOrder>>(	×
NEW 31	&'a self,	×
NEW 32	_f: F,	×
NEW 33	) -> VortexResult<TraversalOrder> {	×
NEW 34	todo!()	×
35	}
36
NEW 37	fn map_children<F: FnMut(Self) -> VortexResult<Transformed<Self>>>(	×
NEW 38	self,	×
NEW 39	f: F,	×
NEW 40	) -> VortexResult<Transformed<Self>> {	×
NEW 41	let transformed = self	×
NEW 42	.children()	×
NEW 43	.iter()	×
NEW 44	.cloned()	×
NEW 45	.collect_vec()	×
NEW 46	.map_elements(f)?;	×
47
NEW 48	if transformed.changed {	×
NEW 49	Ok(Transformed {	×
NEW 50	value: self.with_children(transformed.value),	×
NEW 51	order: transformed.order,	×
NEW 52	changed: true,	×
NEW 53	})	×
54	} else {
NEW 55	Ok(Transformed::no(self))	×
56	}
NEW 57	}	×
58
NEW 59	fn iter_children<T>(&self, f: impl FnOnce(&mut dyn Iterator<Item = &Self>) -> T) -> T {	×
NEW 60	f(&mut self.children().iter())	×
NEW 61	}	×
62
NEW 63	fn children_count(&self) -> usize {	×
NEW 64	self.children().len()	×
NEW 65	}	×
66	}

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