(&mut self, values: &[ArrayRef])
| 281 | } |
| 282 | |
| 283 | fn update_batch(&mut self, values: &[ArrayRef]) -> Result<()> { |
| 284 | let values = values[0].as_primitive::<T>(); |
| 285 | self.all_values.reserve(values.len() - values.null_count()); |
| 286 | self.all_values.extend(values.iter().flatten()); |
| 287 | Ok(()) |
| 288 | } |
| 289 | |
| 290 | fn merge_batch(&mut self, states: &[ArrayRef]) -> Result<()> { |
| 291 | let array = states[0].as_list::<i32>(); |
no test coverage detected