Skip to content

Commit

Permalink
[VL] Merge Partial and PartialMerge logic in generateMergeCompanionNo…
Browse files Browse the repository at this point in the history
…de (apache#4883)
  • Loading branch information
liujiayi771 authored and taiyang-li committed Oct 8, 2024
1 parent 0856952 commit 6b987cf
Showing 1 changed file with 2 additions and 11 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -217,18 +217,9 @@ abstract class HashAggregateExecTransformer(

def generateMergeCompanionNode(): Unit = {
aggregateMode match {
case Partial =>
val partialNode = ExpressionBuilder.makeAggregateFunction(
VeloxAggregateFunctionsBuilder.create(args, aggregateFunction, aggregateMode),
childrenNodeList,
modeKeyWord,
VeloxIntermediateData.getIntermediateTypeNode(aggregateFunction)
)
aggregateNodeList.add(partialNode)
case PartialMerge =>
case Partial | PartialMerge =>
val aggFunctionNode = ExpressionBuilder.makeAggregateFunction(
VeloxAggregateFunctionsBuilder
.create(args, aggregateFunction, aggregateMode),
VeloxAggregateFunctionsBuilder.create(args, aggregateFunction, aggregateMode),
childrenNodeList,
modeKeyWord,
VeloxIntermediateData.getIntermediateTypeNode(aggregateFunction)
Expand Down

0 comments on commit 6b987cf

Please sign in to comment.