Method addSingleGroupSpillInput

bolt/exec/SortedAggregations.cpp:283–297

}

void SortedAggregations::addSingleGroupSpillInput(
    char* group,
    const VectorPtr& input,
    vector_size_t index) {
  auto* arrayVector = input->as<ArrayVector>();
  auto* elementsVector = arrayVector->elements()->asFlatVector<StringView>();

  const auto size = arrayVector->sizeAt(index);
  const auto offset = arrayVector->offsetAt(index);
  for (auto i = 0; i < size; ++i) {
    char* newRow = inputData_->newRow();
    inputData_->storeSerializedRow(*elementsVector, offset + i, newRow);
    addNewRow(group, newRow);
  }
}

bool SortedAggregations::compareRowsWithKeys(
    const char* lhs,