(
&mut self,
emit_to: EmitTo,
)
| 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)] |
no test coverage detected