(&mut self, values: &[ArrayRef])
| 414 | } |
| 415 | |
| 416 | fn update_batch(&mut self, values: &[ArrayRef]) -> Result<()> { |
| 417 | let values = values[0].as_primitive::<T>(); |
| 418 | if let Some(x) = arrow::compute::sum(values) { |
| 419 | let v = self.sum.get_or_insert_with(|| T::Native::usize_as(0)); |
| 420 | *v = v.add_wrapping(x); |
| 421 | } |
| 422 | Ok(()) |
| 423 | } |
| 424 | |
| 425 | fn merge_batch(&mut self, states: &[ArrayRef]) -> Result<()> { |
| 426 | self.update_batch(states) |
no test coverage detected