Function registerAggregateFunc

bolt/exec/tests/AggregateFunctionRegistryTest.cpp:111–133

};

bool registerAggregateFunc(const std::string& name, bool overwrite = false) {
  auto signatures = AggregateFunc::signatures();

  return registerAggregateFunction(
             name,
             std::move(signatures),
             [&](core::AggregationNode::Step step,
                 const std::vector<TypePtr>& argTypes,
                 const TypePtr& resultType,
                 const core::QueryConfig&
                 /*config*/) -> std::unique_ptr<exec::Aggregate> {
               if (isPartialOutput(step)) {
                 if (argTypes.empty()) {
                   return std::make_unique<AggregateFunc>(resultType);
                 }
                 return std::make_unique<AggregateFunc>(ARRAY(resultType));
               }
               return std::make_unique<AggregateFunc>(resultType);
             },
             /*registerCompanionFunctions*/ false,
             overwrite)
      .mainFunction;
}

} // namespace