Method getBatch

bolt/exec/WindowPartition.cpp:655–697

template <RowFormat R>
bool SpilledWindowPartition<R>::getBatch(RowVectorPtr& output, bool& isEnd) {
  bool ret = false;
  RowVectorPtr tmpBatch;
  isEnd = false;

  if constexpr (R == RowFormat::kSerializedRows) {
    std::vector<char*> tmpRows;
    output = nullptr;
    ret = merge_->nextBatch(tmpRows);
    output = std::static_pointer_cast<RowVector>(
        BaseVector::create(outputType_, tmpRows.size(), pool_));
    if (LIKELY(ret)) {
      for (auto i = 0; i < outputChannels_->size(); i++) {
        rowToColumnVector(
            tmpRows.data(),
            tmpRows.size(),
            this->columns_[i],
            0,
            output->childAt(i));
      }

      processedRows_ += output->size();
      isEnd = (processedRows_ == numRows_);
    }
  } else {
    ret = merge_->nextBatch(tmpBatch);
    if (LIKELY(ret)) {
      std::vector<VectorPtr> children(tmpBatch->childrenSize());
      for (auto i = 0; i < outputChannels_->size(); ++i) {
        children[(*outputChannels_)[i]] = tmpBatch->childAt(i);
      }
      output = std::make_shared<RowVector>(
          pool_,
          outputType_,
          BufferPtr(nullptr),
          tmpBatch->size(),
          std::move(children));
      processedRows_ += output->size();
      isEnd = (processedRows_ == numRows_);
    }
  }
  return ret;
}

template <RowFormat R>
void SpilledWindowPartition<R>::getWindowFunctionResults(