Method addDetails

bolt/core/PlanNode.cpp:277–323

  return (isFinal() || isSingle() || isPartial()) && preGroupedKeys().empty() &&
      queryConfig.aggregationSpillEnabled();
}

void AggregationNode::addDetails(std::stringstream& stream) const {
  stream << stepName(step_) << " ";

  if (isPreGrouped()) {
    stream << "STREAMING ";
  }

  if (!groupingKeys_.empty()) {
    stream << "[";
    addFields(stream, groupingKeys_);
    stream << "] ";
  }

  for (auto i = 0; i < aggregateNames_.size(); ++i) {
    appendComma(i, stream);
    const auto& aggregate = aggregates_[i];
    stream << aggregateNames_[i] << " := " << aggregate.call->toString();
    if (aggregate.distinct) {
      stream << " distinct";
    }

    if (aggregate.mask) {
      stream << " mask: " << aggregate.mask->name();
    }

    if (!aggregate.sortingKeys.empty()) {
      stream << " ORDER BY ";
      addSortingKeys(aggregate.sortingKeys, aggregate.sortingOrders, stream);
    }
  }

  if (!globalGroupingSets_.empty()) {
    stream << " global group IDs: [ " << folly::join(", ", globalGroupingSets_)
           << " ]";
  }

  if (groupId_.has_value()) {
    stream << " Group Id key: " << groupId_.value()->name();
  }
  if (ignoreNullKeys_) {
    stream << " ignore null keys";
  }

#if defined BOLT_HAS_CUDF && BOLT_HAS_CUDF == 1
  CudfEnable::addDetails(stream);
#endif
}