| 447 | |
| 448 | namespace { |
| 449 | void reduceRecursive( |
| 450 | const ::cudf::column_view& column, |
| 451 | Aggregator& aggregator, |
| 452 | std::vector<std::unique_ptr<::cudf::column>>& intermediateCols) { |
| 453 | if (column.num_children() > 0) { |
| 454 | for (auto i = 0; i < column.num_children(); ++i) { |
| 455 | reduceRecursive(column.child(i), aggregator, intermediateCols); |
| 456 | } |
| 457 | } else { |
| 458 | auto reduced = aggregator.reduce(column); |
| 459 | intermediateCols.insert( |
| 460 | intermediateCols.end(), |
| 461 | std::make_move_iterator(reduced.begin()), |
| 462 | std::make_move_iterator(reduced.end())); |
| 463 | } |
| 464 | } |
| 465 | } // namespace |
| 466 | |
| 467 | void HashAggregation::runGlobalAggregation() { |
no test coverage detected