Method TrySaveLargeReadPageReservation

be/src/exec/grouping-aggregator.cc:1091–1101

}

bool GroupingAggregator::TrySaveLargeReadPageReservation() {
  DCHECK_EQ(large_read_page_reservation_.GetReservation(), 0);
  int64_t extra_reservation = resource_profile_.max_row_buffer_size
      - resource_profile_.spillable_buffer_size;
  if (buffer_pool_client()->GetUnusedReservation() >= extra_reservation) {
    buffer_pool_client()->SaveReservation(&large_read_page_reservation_,
        extra_reservation);
    return true;
  }
  return false;
}

void GroupingAggregator::RestoreLargeWritePageReservation() {
  DCHECK_GT(large_write_page_reservation_.GetReservation(), 0);