aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorYin Huai <yhuai@databricks.com>2015-07-22 13:28:09 -0700
committerReynold Xin <rxin@databricks.com>2015-07-22 13:28:09 -0700
commitcf21d05f8b5fae52b118fb8846f43d6fda1aea41 (patch)
tree46f295145ed70b0da0995c5b39669715d324c7f0
parent8486cd853104255b4eb013860bba793eef4e74e7 (diff)
downloadspark-cf21d05f8b5fae52b118fb8846f43d6fda1aea41.tar.gz
spark-cf21d05f8b5fae52b118fb8846f43d6fda1aea41.tar.bz2
spark-cf21d05f8b5fae52b118fb8846f43d6fda1aea41.zip
[SPARK-4366] [SQL] [Follow-up] Fix SqlParser compiling warning.
Author: Yin Huai <yhuai@databricks.com> Closes #7588 from yhuai/SPARK-4366-update1 and squashes the following commits: 25f5f36 [Yin Huai] Fix SqlParser Warning.
-rw-r--r--sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/SqlParser.scala3
1 files changed, 1 insertions, 2 deletions
diff --git a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/SqlParser.scala b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/SqlParser.scala
index c04bd6cd85..29cfc064da 100644
--- a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/SqlParser.scala
+++ b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/SqlParser.scala
@@ -271,8 +271,7 @@ class SqlParser extends AbstractSparkSQLParser with DataTypeParser {
lexical.normalizeKeyword(udfName) match {
case "sum" => SumDistinct(exprs.head)
case "count" => CountDistinct(exprs)
- case name => UnresolvedFunction(name, exprs, isDistinct = true)
- case _ => throw new AnalysisException(s"function $udfName does not support DISTINCT")
+ case _ => UnresolvedFunction(udfName, exprs, isDistinct = true)
}
}
| APPROXIMATE ~> ident ~ ("(" ~ DISTINCT ~> expression <~ ")") ^^ { case udfName ~ exp =>