Method TrySaveLargeWritePageReservation

be/src/exec/grouping-aggregator.cc:1078–1089

}

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

bool GroupingAggregator::TrySaveLargeReadPageReservation() {
  DCHECK_EQ(large_read_page_reservation_.GetReservation(), 0);