| 247 | } |
| 248 | |
| 249 | void PythonAggregate::addIntermediateResults( |
| 250 | char** groups, |
| 251 | const SelectivityVector& rows, |
| 252 | const std::vector<VectorPtr>& args, |
| 253 | bool mayPushdown) { |
| 254 | for (const auto& intermediate : args) { |
| 255 | pybind11::object** accumulators = asIntermediatePtrTypes(*intermediate); |
| 256 | rows.applyToSelected([&](vector_size_t i) { |
| 257 | auto& lhs = *value<std::unique_ptr<pybind11::object>>(groups[i]); |
| 258 | accumulate(*lhs, *accumulators[i]); |
| 259 | }); |
| 260 | } |
| 261 | } |
| 262 | |
| 263 | void PythonAggregate::extractValues( |
| 264 | char** groups, |
nothing calls this directly
no test coverage detected