| 224 | } |
| 225 | |
| 226 | void SortedAggregations::initializeNewGroups( |
| 227 | char** groups, |
| 228 | folly::Range<const vector_size_t*> indices) { |
| 229 | for (auto i : indices) { |
| 230 | groups[i][nullByte_] |= nullMask_; |
| 231 | new (groups[i] + offset_) RowPointers(); |
| 232 | } |
| 233 | |
| 234 | for (const auto& [sortingSpec, aggregates] : aggregates_) { |
| 235 | for (const auto& aggregate : aggregates) { |
| 236 | aggregate->function->initializeNewGroups(groups, indices); |
| 237 | } |
| 238 | } |
| 239 | } |
| 240 | |
| 241 | void SortedAggregations::addInput(char** groups, const RowVectorPtr& input) { |
| 242 | for (auto i = 0; i < inputs_.size(); ++i) { |
no outgoing calls
no test coverage detected