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

Method merge_batch

datafusion/functions-aggregate/src/percentile_cont.rs:428–432  ·  view source on GitHub ↗
(&mut self, states: &[ArrayRef])

Source from the content-addressed store, hash-verified

426 }
427
428 fn merge_batch(&mut self, states: &[ArrayRef]) -> Result<()> {
429 let array = states[0].as_list::<i32>();
430 self.update_batch(&[array.value(0)])?;
431 Ok(())
432 }
433
434 fn evaluate(&mut self) -> Result<ScalarValue> {
435 let value = calculate_percentile::<T>(&mut self.all_values, self.percentile);

Callers

nothing calls this directly

Calls 7

newFunction · 0.85
update_batchMethod · 0.45
valueMethod · 0.45
resizeMethod · 0.45
iterMethod · 0.45
extendMethod · 0.45
valuesMethod · 0.45

Tested by

no test coverage detected