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

Method take_state

datafusion/functions-aggregate/src/first_last.rs:497–511  ·  view source on GitHub ↗
(
        &mut self,
        emit_to: EmitTo,
    )

Source from the content-addressed store, hash-verified

495 }
496
497 fn take_state(
498 &mut self,
499 emit_to: EmitTo,
500 ) -> Result<(ArrayRef, Vec<Vec<ScalarValue>>, BooleanBuffer)> {
501 emit_to.take_needed(&mut self.extreme_of_each_group_buf.0);
502 self.extreme_of_each_group_buf
503 .1
504 .truncate(self.extreme_of_each_group_buf.0.len());
505
506 Ok((
507 self.state.take(emit_to)?,
508 self.take_orderings(emit_to),
509 state::take_need(&mut self.is_sets, emit_to),
510 ))
511 }
512
513 // should be used in test only
514 #[cfg(test)]

Callers 2

evaluateMethod · 0.80
stateMethod · 0.80

Calls 6

take_needFunction · 0.85
take_neededMethod · 0.80
take_orderingsMethod · 0.80
truncateMethod · 0.45
lenMethod · 0.45
takeMethod · 0.45

Tested by

no test coverage detected