Method ensureOutputFits

bolt/exec/SpillableWindowBuild.cpp:374–403

// Spill large partitions
template <bool needSort>
void SpillableWindowBuild<needSort>::ensureOutputFits() {
  if (spillConfig_->testSpillPct > 0 && inputRows_.size() > 0) {
    spill();
    return;
  }

  std::optional<size_t> rowLength = std::nullopt;
  if (rowLength_.has_value()) {
    rowLength = rowLength_;
  } else if (estimateRowSize().has_value()) {
    rowLength = estimateRowSize();
  }
  const uint64_t outputBufferSizeToReserve =
      (rowLength.has_value() ? (rowLength.value() * maxBatchRows_)
                             : preferredOutputBatchBytes_) *
      1.2;

  {
    memory::ReclaimableSectionGuard guard(nonReclaimableSection_);
    if (data_->pool()->maybeReserve(outputBufferSizeToReserve)) {
      return;
    }
  }
  LOG(WARNING) << "Failed to reserve "
               << succinctBytes(outputBufferSizeToReserve)
               << " for memory pool " << data_->pool()->name()
               << ", usage: " << succinctBytes(data_->pool()->currentBytes())
               << ", reservation: "
               << succinctBytes(data_->pool()->reservedBytes());
}

template <bool needSort>
void SpillableWindowBuild<needSort>::storeRows() {