Method RestoreLargeReadPageReservation

be/src/exec/grouping-aggregator.cc:1110–1115

}

void GroupingAggregator::RestoreLargeReadPageReservation() {
  int64_t extra_read_reservation = large_read_page_reservation_.GetReservation();
  DCHECK_EQ(extra_read_reservation, resource_profile_.max_row_buffer_size
          - resource_profile_.spillable_buffer_size);
  buffer_pool_client()->RestoreAllReservation(&large_read_page_reservation_);
}

BufferPool::ClientHandle* GroupingAggregator::buffer_pool_client() {
  return reservation_manager_.buffer_pool_client();