(values: &[ArrayRef])
| 1780 | #[test] |
| 1781 | fn test_first_list_acc_size() -> Result<()> { |
| 1782 | fn size_after_batch(values: &[ArrayRef]) -> Result<usize> { |
| 1783 | let mut first_accumulator = TrivialFirstValueAccumulator::try_new( |
| 1784 | &DataType::List(Arc::new(Field::new_list_field(DataType::Int64, false))), |
| 1785 | false, |
| 1786 | )?; |
| 1787 | |
| 1788 | first_accumulator.update_batch(values)?; |
| 1789 | |
| 1790 | Ok(first_accumulator.size()) |
| 1791 | } |
| 1792 | |
| 1793 | let batch1 = ListArray::from_iter_primitive::<Int32Type, _, _>( |
| 1794 | repeat_with(|| Some(vec![Some(1)])).take(10000), |
searching dependent graphs…