Method createHashTable

bolt/exec/GroupingSet.cpp:402–460

}

void GroupingSet::createHashTable() {
  bool jitRowEqVectors = queryConfig_.enableJitRowEqVectors();
  if (ignoreNullKeys_) {
    table_ = HashTable<true>::createForAggregation(
        std::move(hashers_),
        accumulators(false),
        &pool_,
        nullptr,
        jitRowEqVectors);
  } else {
    table_ = HashTable<false>::createForAggregation(
        std::move(hashers_),
        accumulators(false),
        &pool_,
        nullptr,
        jitRowEqVectors);
  }

  RowContainer& rows = *table_->rows();
  initializeAggregates(aggregates_, rows, false);

  auto numColumns = rows.keyTypes().size() + aggregates_.size();

  if (sortedAggregations_) {
    sortedAggregations_->setAllocator(&rows.stringAllocator());

    const auto rowColumn = rows.columnAt(numColumns);
    sortedAggregations_->setOffsets(
        rowColumn.offset(),
        rowColumn.nullByte(),
        rowColumn.nullMask(),
        rows.rowSizeOffset());

    ++numColumns;
  }

  for (const auto& aggregation : distinctAggregations_) {
    if (aggregation != nullptr) {
      aggregation->setAllocator(&rows.stringAllocator());

      const auto rowColumn = rows.columnAt(numColumns);
      aggregation->setOffsets(
          rowColumn.offset(),
          rowColumn.nullByte(),
          rowColumn.nullMask(),
          rows.rowSizeOffset());
      ++numColumns;
    }
  }

  lookup_ = std::make_unique<HashLookup>(table_->hashers(), jitRowEqVectors);
  if (!isAdaptive_ && table_->hashMode() != BaseHashTable::HashMode::kHash) {
    table_->forceGenericHashMode();
  }

  rowInfo_ = std::make_optional<RowFormatInfo>(table_->rows(), true);
  LOG(INFO) << __FUNCTION__ << "=============RowContainer details "
            << rows.toString() << ", alignment = " << rows.alignment();