| 233 | } |
| 234 | |
| 235 | void PythonAggregate::addSingleGroupIntermediateResults( |
| 236 | char* group, |
| 237 | const SelectivityVector& rows, |
| 238 | const std::vector<VectorPtr>& args, |
| 239 | [[maybe_unused]] bool mayPushdown) { |
| 240 | auto& lhs = *value<std::unique_ptr<pybind11::object>>(group); |
| 241 | |
| 242 | for (const auto& intermediate : args) { |
| 243 | pybind11::object** accumulators = asIntermediatePtrTypes(*intermediate); |
| 244 | rows.applyToSelected( |
| 245 | [&](vector_size_t i) { accumulate(*lhs, *accumulators[i]); }); |
| 246 | } |
| 247 | } |
| 248 | |
| 249 | void PythonAggregate::addIntermediateResults( |
| 250 | char** groups, |
nothing calls this directly
no test coverage detected