Method copyKeyAndUpdateGroups

bolt/exec/GroupingSet.cpp:1321–1353

          }
        }
      }

      for (auto& aggregate : aggregates_) {
        BOLT_CHECK(aggregate.sortingKeys.empty());
        aggregate.function->initializeNewGroups(
            groups.data(),
            folly::Range<const vector_size_t*>(
                groupIndicesOfRows_.data() + initGroupCount,
                groups.size() - initGroupCount));
      }
    }
    initGroupCount = distinctRows.size();
  }
}

void GroupingSet::copyKeyAndUpdateGroups(
    std::vector<char*>& rows,
    std::vector<char*>& groupOfRows,
    std::vector<char*>& distinctRows,
    std::vector<char*>& groups,
    size_t& initGroupCount,
    const RowContainer* container,
    const RowVectorPtr& result,
    const vector_size_t resultOffset) {
  if (rows.empty()) {
    return;
  }
  BOLT_CHECK_EQ(rows.size(), groupOfRows.size());
  copyKeyAndInitGroup(
      distinctRows, groups, initGroupCount, container, result, resultOffset);
  NanosecondTimer aggTimer(&stats_.aggOutputUpdateTimeNs);
  // calculate rows into groupOfRows
  SelectivityVector selections(groupOfRows.size());
  auto& accumulators = container->accumulators();
  BOLT_CHECK_EQ(accumulators.size(), aggregates_.size());
  for (auto i = 0; i < aggregates_.size(); ++i) {