MCPcopy Create free account
hub / github.com/apache/datafusion / size_after_batch

Function size_after_batch

datafusion/functions-aggregate/src/first_last.rs:1782–1791  ·  view source on GitHub ↗
(values: &[ArrayRef])

Source from the content-addressed store, hash-verified

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),

Callers 2

test_first_list_acc_sizeFunction · 0.85
test_last_list_acc_sizeFunction · 0.85

Calls 4

newFunction · 0.85
ListClass · 0.50
update_batchMethod · 0.45
sizeMethod · 0.45

Tested by 2

test_first_list_acc_sizeFunction · 0.68
test_last_list_acc_sizeFunction · 0.68

Used in the wild real call sites across dependent graphs

searching dependent graphs…