Method create

bolt/core/PlanNode.cpp:458–498

static

// static
PlanNodePtr AggregationNode::create(const folly::dynamic& obj, void* context) {
  auto source = deserializeSingleSource(obj, context);

  auto groupingKeys = deserializeFields(obj["groupingKeys"], context);
  auto preGroupedKeys = deserializeFields(obj["preGroupedKeys"], context);
  auto aggregateNames = deserializeStrings(obj["aggregateNames"]);

  std::vector<Aggregate> aggregates;
  for (const auto& aggregate : obj["aggregates"]) {
    aggregates.push_back(Aggregate::deserialize(aggregate, context));
  }

  std::vector<vector_size_t> globalGroupingSets;
  for (const auto& globalSet : obj["globalGroupingSets"]) {
    globalGroupingSets.push_back(globalSet.asInt());
  }

  std::optional<FieldAccessTypedExprPtr> groupId;
  if (obj.count("groupId")) {
    groupId = ISerializable::deserialize<FieldAccessTypedExpr>(
        obj["groupId"], context);
  }

  auto planNode = std::make_shared<AggregationNode>(
      deserializePlanNodeId(obj),
      stepFromName(obj["step"].asString()),
      groupingKeys,
      preGroupedKeys,
      aggregateNames,
      aggregates,
      globalGroupingSets,
      groupId,
      obj["ignoreNullKeys"].asBool(),
      deserializeSingleSource(obj, context));

#if defined BOLT_HAS_CUDF && BOLT_HAS_CUDF == 1
  planNode->enableCudfIfDesired(obj);
#endif

  return planNode;
}

namespace {
RowTypePtr getExpandOutputType(