| 1558 | } |
| 1559 | |
| 1560 | fn build(&self) -> Result<Box<dyn Accumulator>> { |
| 1561 | let expr = Arc::new(Column::new("col", 0)); |
| 1562 | let expr_field = expr.return_field(&self.schema)?; |
| 1563 | ArrayAgg::default().accumulator(AccumulatorArgs { |
| 1564 | return_field: Arc::clone(&self.return_field), |
| 1565 | schema: &self.schema, |
| 1566 | expr_fields: &[expr_field], |
| 1567 | ignore_nulls: false, |
| 1568 | order_bys: &self.order_bys, |
| 1569 | is_reversed: false, |
| 1570 | name: "", |
| 1571 | is_distinct: self.distinct, |
| 1572 | exprs: &[expr], |
| 1573 | }) |
| 1574 | } |
| 1575 | |
| 1576 | fn build_two(&self) -> Result<(Box<dyn Accumulator>, Box<dyn Accumulator>)> { |
| 1577 | Ok((self.build()?, self.build()?)) |