(
mut acc1: Box<dyn Accumulator>,
mut acc2: Box<dyn Accumulator>,
)
| 773 | } |
| 774 | |
| 775 | fn merge( |
| 776 | mut acc1: Box<dyn Accumulator>, |
| 777 | mut acc2: Box<dyn Accumulator>, |
| 778 | ) -> Result<Box<dyn Accumulator>> { |
| 779 | let intermediate_state = acc2.state().and_then(|e| { |
| 780 | e.iter() |
| 781 | .map(|v| v.to_array()) |
| 782 | .collect::<Result<Vec<ArrayRef>>>() |
| 783 | })?; |
| 784 | acc1.merge_batch(&intermediate_state)?; |
| 785 | Ok(acc1) |
| 786 | } |
| 787 | |
| 788 | // --------------------------------------------------------------- |
| 789 | // Tests for StringAggGroupsAccumulator |
searching dependent graphs…