| 58 | } |
| 59 | } |
| 60 | void LocalShuffle::shuffle() { |
| 61 | shuffledRows_.resize(currentRows_); |
| 62 | RowContainerIterator iter; |
| 63 | data_->listRows(&iter, currentRows_, shuffledRows_.data()); |
| 64 | std::shuffle(shuffledRows_.begin(), shuffledRows_.end(), gen_); |
| 65 | shuffled_ = true; |
| 66 | pool()->release(); |
| 67 | } |
| 68 | |
| 69 | void LocalShuffle::prepareOutput() { |
| 70 | BOLT_CHECK_GT(maxOutputRows_, 0); |