-
- Downloads
[SPARK-18932][SQL] Support partial aggregation for collect_set/collect_list
## What changes were proposed in this pull request? Currently collect_set/collect_list aggregation expression don't support partial aggregation. This patch is to enable partial aggregation for them. ## How was this patch tested? Jenkins tests. Please review http://spark.apache.org/contributing.html before opening a pull request. Author: Liang-Chi Hsieh <viirya@gmail.com> Closes #16371 from viirya/collect-partial-support.
Showing
- sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/aggregate/Percentile.scala 3 additions, 4 deletions...spark/sql/catalyst/expressions/aggregate/Percentile.scala
- sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/aggregate/collect.scala 33 additions, 29 deletions...he/spark/sql/catalyst/expressions/aggregate/collect.scala
- sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/aggregate/interfaces.scala 3 additions, 1 deletion...spark/sql/catalyst/expressions/aggregate/interfaces.scala
- sql/catalyst/src/test/scala/org/apache/spark/sql/catalyst/optimizer/RewriteDistinctAggregatesSuite.scala 0 additions, 9 deletions...l/catalyst/optimizer/RewriteDistinctAggregatesSuite.scala
Loading
Please register or sign in to comment