| 262 | } |
| 263 | |
| 264 | void SortedAggregations::addSingleGroupInput( |
| 265 | char* group, |
| 266 | const RowVectorPtr& input) { |
| 267 | for (auto i = 0; i < inputs_.size(); ++i) { |
| 268 | decodedInputs_[i].decode(*input->childAt(inputs_[i])); |
| 269 | } |
| 270 | |
| 271 | // Add all the rows into the RowContainer. |
| 272 | for (auto row = 0; row < input->size(); ++row) { |
| 273 | char* newRow = inputData_->newRow(); |
| 274 | |
| 275 | for (auto i = 0; i < inputs_.size(); ++i) { |
| 276 | inputData_->store(decodedInputs_[i], row, newRow, i); |
| 277 | } |
| 278 | |
| 279 | addNewRow(group, newRow); |
| 280 | } |
| 281 | } |
| 282 | |
| 283 | void SortedAggregations::addSingleGroupSpillInput( |
| 284 | char* group, |