Method MustSortAndSpill

be/src/runtime/sorter.cc:1258–1266

}

bool Sorter::MustSortAndSpill(const int rows_added, const int batch_num_rows) {
  if (rows_added < batch_num_rows) {
    return true;
  } else if (enforce_sort_run_bytes_limit_) {
    int used_reservation = buffer_pool_client_->GetUsedReservation();
    return GetSortRunBytesLimit() < used_reservation;
  }
  return false;
}

void Sorter::TryLowerMemUpToSortRunBytesLimit() {
  DCHECK(enforce_sort_run_bytes_limit_);