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

Method retract_batch

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

Source from the content-addressed store, hash-verified

407 }
408
409 fn retract_batch(&mut self, values: &[ArrayRef]) -> Result<()> {
410 for _idx in 0..values[0].len() {
411 (self.moving_max).pop();
412 }
413 if let Some(res) = self.moving_max.max() {
414 self.max = res.clone();
415 }
416 Ok(())
417 }
418
419 fn merge_batch(&mut self, states: &[ArrayRef]) -> Result<()> {
420 self.update_batch(states)

Callers

nothing calls this directly

Calls 6

lenMethod · 0.45
popMethod · 0.45
maxMethod · 0.45
cloneMethod · 0.45
is_nullMethod · 0.45
minMethod · 0.45

Tested by

no test coverage detected