1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22

use vortex_error::VortexResult;

use crate::array::chunked::ChunkedArray;
use crate::stats::{ArrayStatistics, ArrayStatisticsCompute, Stat, StatsSet};

impl ArrayStatisticsCompute for ChunkedArray {
    fn compute_statistics(&self, stat: Stat) -> VortexResult<StatsSet> {
        Ok(self
            .chunks()
            .map(|c| {
                let s = c.statistics();
                // HACK(robert): This will compute all stats, but we could just compute one
                s.compute(stat);
                s.to_set()
            })
            .reduce(|mut acc, x| {
                acc.merge(&x);
                acc
            })
            .unwrap_or_default())
    }
}