| 274 | dest, tmpSortedRows_[i], tmpSortedRowsSize_[i], *info_); |
| 275 | offset += tmpSortedRowsSize_[i]; |
| 276 | sortRows_.push_back(dest); |
| 277 | } |
| 278 | tmpSortedRows_.clear(); |
| 279 | tmpSortedRowsSize_.clear(); |
| 280 | accumulatedLength_ = 0; |
| 281 | } |
| 282 | |
| 283 | void SortWindowBuild::loadNextPartitionFromSpill() { |
| 284 | if (sortMerge_) { |
| 285 | BOLT_CHECK_NOT_NULL(sortMerge_); |
| 286 | sortRows_.clear(); |
| 287 | if (data_->numRows()) { |
| 288 | data_->clear(); |
| 289 | } |
| 290 | for (;;) { |
| 291 | auto next = sortMerge_->next(); |
| 292 | if (next == nullptr) { |
| 293 | break; |
| 294 | } |
| 295 | |
| 296 | bool newPartition = false; |
| 297 | if (!sortRows_.empty()) { |
| 298 | CompareFlags compareFlags = CompareFlags::equality( |