(&mut self, values: &[ArrayRef])
| 419 | } |
| 420 | |
| 421 | fn update_batch(&mut self, values: &[ArrayRef]) -> Result<()> { |
| 422 | let values = values[0].as_primitive::<T>(); |
| 423 | self.all_values.reserve(values.len() - values.null_count()); |
| 424 | self.all_values.extend(values.iter().flatten()); |
| 425 | Ok(()) |
| 426 | } |
| 427 | |
| 428 | fn merge_batch(&mut self, states: &[ArrayRef]) -> Result<()> { |
| 429 | let array = states[0].as_list::<i32>(); |
no test coverage detected