Method noMoreInputCommon

bolt/exec/WindowBuild.cpp:186–220

}

void WindowBuild::noMoreInputCommon() {
  if (numRows_ == 0) {
    return;
  }

  if (sortSpiller_ != nullptr) {
    // Spill remaining data to avoid running out of memory while sort-merging
    // spilled data.
    sortSpill();

    BOLT_CHECK_NULL(sortMerge_);
    BOLT_CHECK_NULL(rowBasedSpillSortMerger_);
    auto spillPartition = sortSpiller_->finishSpill();
    if (spillConfig_->rowBasedSpillMode == common::RowBasedSpillMode::DISABLE) {
      sortMerge_ = spillPartition.createOrderedReader(pool_);
    } else {
      rowBasedSpillSortMerger_ =
          spillPartition.createRowBasedOrderedReaderWithLength(
              pool_,
              data_.get(),
              spillConfig_->getJITenabledForSpill(),
              spillConfig_->spillUringEnabled);
    }

  } else {
    // At this point we have seen all the input rows. The operator is
    // being prepared to output rows now.
    // To prepare the rows for output in SortWindowBuild they need to
    // be separated into partitions and sort by ORDER BY keys within
    // the partition. This will order the rows for getOutput().
    updateEstimatedOutputRowSize();
    sortPartitions();
    return;
  }
}

void WindowBuild::sortPartitions() {
  sortRows_.resize(numRows_);