Method RestoreLargeWritePageReservation

be/src/exec/grouping-aggregator.cc:1103–1108

}

void GroupingAggregator::RestoreLargeWritePageReservation() {
  DCHECK_GT(large_write_page_reservation_.GetReservation(), 0);
  DCHECK_EQ(large_write_page_reservation_.GetReservation(),
      resource_profile_.max_row_buffer_size - resource_profile_.spillable_buffer_size);
  buffer_pool_client()->RestoreAllReservation(&large_write_page_reservation_);
}

void GroupingAggregator::RestoreLargeReadPageReservation() {
  int64_t extra_read_reservation = large_read_page_reservation_.GetReservation();