Execute sort aggregation
(
&self,
group_by: &[Expression],
aggregates: &[crate::plan::physical::AggregateItem],
input_rows: Vec<Row>,
context: &mut ExecutionContext,
)
| 5726 | |
| 5727 | /// Execute sort aggregation |
| 5728 | fn execute_sort_aggregate( |
| 5729 | &self, |
| 5730 | group_by: &[Expression], |
| 5731 | aggregates: &[crate::plan::physical::AggregateItem], |
| 5732 | input_rows: Vec<Row>, |
| 5733 | context: &mut ExecutionContext, |
| 5734 | ) -> Result<Vec<Row>, ExecutionError> { |
| 5735 | self.execute_aggregate(group_by, aggregates, input_rows, context) |
| 5736 | } |
| 5737 | |
| 5738 | /// Common aggregation logic |
| 5739 | fn execute_aggregate( |
no test coverage detected