| 129 | } |
| 130 | |
| 131 | Stream Stream::shuffle(int64_t buffer_size) const { |
| 132 | return Stream(std::make_shared<stream::Shuffle>(self_, buffer_size)); |
| 133 | } |
| 134 | Stream Stream::shuffle_if(bool cond, int64_t buffer_size) const { |
| 135 | if (cond) { |
| 136 | return shuffle(buffer_size); |