| 1421 | } |
| 1422 | |
| 1423 | Status Sorter::SortCurrentInputRun() { |
| 1424 | RETURN_IF_ERROR(unsorted_run_->FinalizeInput()); |
| 1425 | |
| 1426 | { |
| 1427 | SCOPED_TIMER(in_mem_sort_timer_); |
| 1428 | RETURN_IF_ERROR(in_mem_tuple_sorter_->Sort(unsorted_run_)); |
| 1429 | } |
| 1430 | sorted_data_size_->Add(unsorted_run_->TotalBytes()); |
| 1431 | run_sizes_->UpdateCounter(unsorted_run_->num_tuples()); |
| 1432 | |
| 1433 | RETURN_IF_CANCELLED(state_); |
| 1434 | return Status::OK(); |
| 1435 | } |
| 1436 | |
| 1437 | int Sorter::MaxRunsInNextMerge() const { |
| 1438 | int num_available_buffers = buffer_pool_client_->GetUnusedReservation() / page_len_; |
nothing calls this directly
no test coverage detected