• Home
  • Features
  • Pricing
  • Docs
  • Announcements
  • Sign In

vortex-data / vortex / 16970635821

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

Pull #4215

github

web-flow
Merge 5182504a6 into f547cbca5
Pull Request #4215: Ji/vectors

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-expr/src/traversal/operator.rs
1
use std::sync::Arc;
2

3
use itertools::Itertools;
4
use pipeline::operators::Operator;
5
use vortex_array::pipeline;
6
use vortex_error::VortexResult;
7

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

10
impl<'a> NodeContainer<'a, Self> for Arc<dyn Operator> {
NEW
11
    fn apply_elements<F: FnMut(&'a Self) -> VortexResult<TraversalOrder>>(
×
NEW
12
        &'a self,
×
NEW
13
        mut f: F,
×
NEW
14
    ) -> VortexResult<TraversalOrder> {
×
NEW
15
        f(self)
×
NEW
16
    }
×
17

NEW
18
    fn map_elements<F: FnMut(Self) -> VortexResult<Transformed<Self>>>(
×
NEW
19
        self,
×
NEW
20
        mut f: F,
×
NEW
21
    ) -> VortexResult<Transformed<Self>> {
×
NEW
22
        f(self)
×
NEW
23
    }
×
24
}
25

26
impl Node for Arc<dyn Operator> {
NEW
27
    fn apply_children<'a, F: FnMut(&'a Self) -> VortexResult<TraversalOrder>>(
×
NEW
28
        &'a self,
×
NEW
29
        _f: F,
×
NEW
30
    ) -> VortexResult<TraversalOrder> {
×
NEW
31
        todo!()
×
32
    }
33

NEW
34
    fn map_children<F: FnMut(Self) -> VortexResult<Transformed<Self>>>(
×
NEW
35
        self,
×
NEW
36
        f: F,
×
NEW
37
    ) -> VortexResult<Transformed<Self>> {
×
NEW
38
        let transformed = self
×
NEW
39
            .children()
×
NEW
40
            .iter()
×
NEW
41
            .cloned()
×
NEW
42
            .collect_vec()
×
NEW
43
            .map_elements(f)?;
×
44

NEW
45
        if transformed.changed {
×
NEW
46
            Ok(Transformed {
×
NEW
47
                value: self.with_children(transformed.value),
×
NEW
48
                order: transformed.order,
×
NEW
49
                changed: true,
×
NEW
50
            })
×
51
        } else {
NEW
52
            Ok(Transformed::no(self))
×
53
        }
NEW
54
    }
×
55

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

NEW
60
    fn children_count(&self) -> usize {
×
NEW
61
        self.children().len()
×
NEW
62
    }
×
63
}
STATUS · Troubleshooting · Open an Issue · Sales · Support · CAREERS · ENTERPRISE · START FREE · SCHEDULE DEMO
ANNOUNCEMENTS · TWITTER · TOS & SLA · Supported CI Services · What's a CI service? · Automated Testing

© 2026 Coveralls, Inc