diff options
| author | Wenchen Fan <cloud0fan@163.com> | 2015-09-24 09:54:07 -0700 |
|---|---|---|
| committer | Yin Huai <yhuai@databricks.com> | 2015-09-24 09:54:07 -0700 |
| commit | 341b13f8f5eb118f1fb4d4f84418715ac4750a4d (patch) | |
| tree | e6b8d90482e7d8e6cc339a6f357d320e92d7e8ff /sql/catalyst/src | |
| parent | 02144d6745ec0a6d8877d969feb82139bd22437f (diff) | |
| download | spark-341b13f8f5eb118f1fb4d4f84418715ac4750a4d.tar.gz spark-341b13f8f5eb118f1fb4d4f84418715ac4750a4d.tar.bz2 spark-341b13f8f5eb118f1fb4d4f84418715ac4750a4d.zip | |
[SPARK-10765] [SQL] use new aggregate interface for hive UDAF
Author: Wenchen Fan <cloud0fan@163.com>
Closes #8874 from cloud-fan/hive-agg.
Diffstat (limited to 'sql/catalyst/src')
| -rw-r--r-- | sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/aggregate/interfaces.scala | 7 |
1 files changed, 6 insertions, 1 deletions
diff --git a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/aggregate/interfaces.scala b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/aggregate/interfaces.scala index 576d8c7a3a..d8699533cd 100644 --- a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/aggregate/interfaces.scala +++ b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/aggregate/interfaces.scala @@ -17,7 +17,6 @@ package org.apache.spark.sql.catalyst.expressions.aggregate -import org.apache.spark.sql.catalyst.errors.TreeNodeException import org.apache.spark.sql.catalyst.expressions._ import org.apache.spark.sql.catalyst.expressions.codegen.{GeneratedExpressionCode, CodeGenContext} import org.apache.spark.sql.catalyst.InternalRow @@ -169,6 +168,12 @@ abstract class AggregateFunction2 override protected def genCode(ctx: CodeGenContext, ev: GeneratedExpressionCode): String = throw new UnsupportedOperationException(s"Cannot evaluate expression: $this") + + /** + * Indicates if this function supports partial aggregation. + * Currently Hive UDAF is the only one that doesn't support partial aggregation. + */ + def supportsPartial: Boolean = true } /** |