(&mut self, values: &[ArrayRef])
| 250 | |
| 251 | impl Accumulator for StringAggAccumulator { |
| 252 | fn update_batch(&mut self, values: &[ArrayRef]) -> Result<()> { |
| 253 | self.array_agg_acc.update_batch(&filter_index(values, 1)) |
| 254 | } |
| 255 | |
| 256 | fn evaluate(&mut self) -> Result<ScalarValue> { |
| 257 | let scalar = self.array_agg_acc.evaluate()?; |