| 195 | } |
| 196 | |
| 197 | Status SortNode::Reset(RuntimeState* state, RowBatch* row_batch) { |
| 198 | num_rows_skipped_ = 0; |
| 199 | if (sorter_.get() != NULL) sorter_->Reset(); |
| 200 | return ExecNode::Reset(state, row_batch); |
| 201 | } |
| 202 | |
| 203 | void SortNode::Close(RuntimeState* state) { |
| 204 | if (is_closed()) return; |