| 379 | } |
| 380 | |
| 381 | Status TopNNode::GetNext(RuntimeState* state, RowBatch* row_batch, bool* eos) { |
| 382 | SCOPED_TIMER(runtime_profile_->total_time_counter()); |
| 383 | ScopedGetNextEventAdder ea(this, eos); |
| 384 | RETURN_IF_ERROR(ExecDebugAction(TExecNodePhase::GETNEXT, state)); |
| 385 | return is_partitioned() ? GetNextPartitioned(state, row_batch, eos) |
| 386 | : GetNextUnpartitioned(state, row_batch, eos); |
| 387 | } |
| 388 | |
| 389 | Status TopNNode::GetNextUnpartitioned( |
| 390 | RuntimeState* state, RowBatch* row_batch, bool* eos) { |