| 101 | } |
| 102 | |
| 103 | Status PartialSortNode::Open(RuntimeState* state) { |
| 104 | SCOPED_TIMER(runtime_profile_->total_time_counter()); |
| 105 | ScopedOpenEventAdder ea(this); |
| 106 | RETURN_IF_ERROR(ExecNode::Open(state)); |
| 107 | RETURN_IF_CANCELLED(state); |
| 108 | RETURN_IF_ERROR(QueryMaintenance(state)); |
| 109 | RETURN_IF_ERROR(child(0)->Open(state)); |
| 110 | if (!buffer_pool_client()->is_registered()) { |
| 111 | RETURN_IF_ERROR(ClaimBufferReservation(state)); |
| 112 | } |
| 113 | return Status::OK(); |
| 114 | } |
| 115 | |
| 116 | Status PartialSortNode::GetNext(RuntimeState* state, RowBatch* row_batch, bool* eos) { |
| 117 | SCOPED_TIMER(runtime_profile_->total_time_counter()); |
no test coverage detected