| 874 | } |
| 875 | |
| 876 | int64_t Sorter::Run::TotalBytes() const { |
| 877 | int64_t total_bytes = 0; |
| 878 | for (const Page& page : fixed_len_pages_) { |
| 879 | if (page.is_open()) total_bytes += page.valid_data_len(); |
| 880 | } |
| 881 | |
| 882 | for (const Page& page : var_len_pages_) { |
| 883 | if (page.is_open()) total_bytes += page.valid_data_len(); |
| 884 | } |
| 885 | return total_bytes; |
| 886 | } |
| 887 | |
| 888 | Status Sorter::Run::AddInputBatch(RowBatch* batch, int start_index, int* num_processed, |
| 889 | bool* allocation_failed) { |
no test coverage detected