| 265 | } |
| 266 | |
| 267 | Status GroupingAggregator::GetNext(RuntimeState* state, RowBatch* row_batch, bool* eos) { |
| 268 | RETURN_IF_ERROR(QueryMaintenance(state)); |
| 269 | if (!partition_eos_) { |
| 270 | RETURN_IF_ERROR(GetRowsFromPartition(state, row_batch)); |
| 271 | } |
| 272 | *eos = partition_eos_; |
| 273 | return Status::OK(); |
| 274 | } |
| 275 | |
| 276 | Status GroupingAggregator::GetRowsFromPartition( |
| 277 | RuntimeState* state, RowBatch* row_batch) { |