(self, aggregates: &[AggregateSpec])
| 95 | } |
| 96 | |
| 97 | pub(crate) fn finalize(self, aggregates: &[AggregateSpec]) -> Vec<(String, Value)> { |
| 98 | self.accums |
| 99 | .into_iter() |
| 100 | .zip(aggregates) |
| 101 | .map(|(accum, agg)| (agg.alias.clone(), accum.finalize(agg))) |
| 102 | .collect() |
| 103 | } |
| 104 | } |