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

Method update_with_new_row

datafusion/functions-aggregate/src/first_last.rs:867–875  ·  view source on GitHub ↗

Updates state with the values in the given row.

(&mut self, mut row: Vec<ScalarValue>)

Source from the content-addressed store, hash-verified

865
866 // Updates state with the values in the given row.
867 fn update_with_new_row(&mut self, mut row: Vec<ScalarValue>) {
868 // Ensure any Array based scalars hold have a single value to reduce memory pressure
869 for s in row.iter_mut() {
870 s.compact();
871 }
872 self.first = row.remove(0);
873 self.orderings = row;
874 self.is_set = true;
875 }
876
877 fn get_first_idx(&self, values: &[ArrayRef]) -> Result<Option<usize>> {
878 let [value, ordering_values @ ..] = values else {

Callers 2

update_batchMethod · 0.80
merge_batchMethod · 0.80

Calls 2

compactMethod · 0.45
removeMethod · 0.45

Tested by

no test coverage detected