We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 29cc149 commit a170f43Copy full SHA for a170f43
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/Analyzer.scala
@@ -562,7 +562,8 @@ class Analyzer(
562
registry.lookupFunction(name, children) match {
563
// We get an aggregate function built based on AggregateFunction2 interface.
564
// So, we wrap it in AggregateExpression2.
565
- case agg2: AggregateFunction2 => AggregateExpression2(agg2, Complete, isDistinct)
+ case agg2: AggregateFunction2 =>
566
+ AggregateExpression2(agg2, Complete, isDistinct)
567
// Currently, our old aggregate function interface supports SUM(DISTINCT ...)
568
// and COUTN(DISTINCT ...).
569
case sumDistinct: SumDistinct => sumDistinct
0 commit comments