Skip to content

Commit 84ac387

Browse files
committed
feat: support PartialMerge
1 parent 6d04b60 commit 84ac387

1 file changed

Lines changed: 2 additions & 2 deletions

File tree

spark/src/main/scala/org/apache/spark/sql/comet/operators.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -30,7 +30,7 @@ import org.apache.spark.broadcast.Broadcast
3030
import org.apache.spark.rdd.RDD
3131
import org.apache.spark.sql.catalyst.InternalRow
3232
import org.apache.spark.sql.catalyst.expressions.{Ascending, Attribute, AttributeSet, Expression, ExpressionSet, Generator, NamedExpression, SortOrder}
33-
import org.apache.spark.sql.catalyst.expressions.aggregate.{AggregateExpression, AggregateMode, CollectSet, Final, Partial, PartialMerge}
33+
import org.apache.spark.sql.catalyst.expressions.aggregate.{AggregateExpression, AggregateMode, CollectSet, Final, First, Last, Partial, PartialMerge}
3434
import org.apache.spark.sql.catalyst.optimizer.{BuildLeft, BuildRight, BuildSide}
3535
import org.apache.spark.sql.catalyst.plans._
3636
import org.apache.spark.sql.catalyst.plans.physical._
@@ -1470,7 +1470,7 @@ trait CometBaseAggregate {
14701470
if (unsupportedAggs.nonEmpty) {
14711471
withInfo(
14721472
aggregate,
1473-
s"PartialMerge not supported for order-dependent aggregates: " +
1473+
"PartialMerge not supported for order-dependent aggregates: " +
14741474
unsupportedAggs.map(_.aggregateFunction.prettyName).mkString(", "))
14751475
return None
14761476
}

0 commit comments

Comments
 (0)