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 cf1995a commit a4d26b3Copy full SHA for a4d26b3
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/aggregate/interfaces.scala
@@ -174,8 +174,8 @@ sealed abstract class AggregateFunction extends Expression with ImplicitCastInpu
174
def inputAggBufferAttributes: Seq[AttributeReference]
175
176
/**
177
- * Indicates if this function supports partial aggregation.
178
- * Currently Hive UDAF is the only one that doesn't support partial aggregation.
+ * Indicates if this function needs to aggregate values group-by-group in a single step.
+ * If false, we must always use a `SortAggregateExec` operator without partial aggregates.
179
*/
180
def supportsPartial: Boolean = true
181
0 commit comments