You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by rx...@apache.org on 2015/07/22 22:28:11 UTC
spark git commit: [SPARK-4366] [SQL] [Follow-up] Fix SqlParser
compiling warning.
Repository: spark
Updated Branches:
refs/heads/master 8486cd853 -> cf21d05f8
[SPARK-4366] [SQL] [Follow-up] Fix SqlParser compiling warning.
Author: Yin Huai <yh...@databricks.com>
Closes #7588 from yhuai/SPARK-4366-update1 and squashes the following commits:
25f5f36 [Yin Huai] Fix SqlParser Warning.
Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/cf21d05f
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/cf21d05f
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/cf21d05f
Branch: refs/heads/master
Commit: cf21d05f8b5fae52b118fb8846f43d6fda1aea41
Parents: 8486cd8
Author: Yin Huai <yh...@databricks.com>
Authored: Wed Jul 22 13:28:09 2015 -0700
Committer: Reynold Xin <rx...@databricks.com>
Committed: Wed Jul 22 13:28:09 2015 -0700
----------------------------------------------------------------------
.../src/main/scala/org/apache/spark/sql/catalyst/SqlParser.scala | 3 +--
1 file changed, 1 insertion(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/spark/blob/cf21d05f/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/SqlParser.scala
----------------------------------------------------------------------
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 c04bd6c..29cfc06 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 =>
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org