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

Method update_batch

datafusion/functions-aggregate/src/median.rs:283–288  ·  view source on GitHub ↗
(&mut self, values: &[ArrayRef])

Source from the content-addressed store, hash-verified

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>();

Callers 1

merge_batchMethod · 0.45

Calls 10

newFunction · 0.85
accumulateFunction · 0.85
reserveMethod · 0.80
null_countMethod · 0.80
flattenMethod · 0.80
lenMethod · 0.45
extendMethod · 0.45
iterMethod · 0.45
resizeMethod · 0.45
pushMethod · 0.45

Tested by

no test coverage detected