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/27 08:58:06 UTC
spark git commit: [SPARK-9371][SQL] fix the support for special chars
in column names for hive context
Repository: spark
Updated Branches:
refs/heads/master aa80c64fc -> 4ffd3a1db
[SPARK-9371][SQL] fix the support for special chars in column names for hive context
Author: Wenchen Fan <cl...@outlook.com>
Closes #7684 from cloud-fan/hive and squashes the following commits:
da21ffe [Wenchen Fan] fix the support for special chars in column names for hive context
Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/4ffd3a1d
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/4ffd3a1d
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/4ffd3a1d
Branch: refs/heads/master
Commit: 4ffd3a1db5ecff653b02aa325786e734351c8bd2
Parents: aa80c64
Author: Wenchen Fan <cl...@outlook.com>
Authored: Sun Jul 26 23:58:03 2015 -0700
Committer: Reynold Xin <rx...@databricks.com>
Committed: Sun Jul 26 23:58:03 2015 -0700
----------------------------------------------------------------------
.../src/main/scala/org/apache/spark/sql/hive/HiveQl.scala | 6 +++---
.../org/apache/spark/sql/hive/execution/SQLQuerySuite.scala | 8 ++++++++
2 files changed, 11 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/spark/blob/4ffd3a1d/sql/hive/src/main/scala/org/apache/spark/sql/hive/HiveQl.scala
----------------------------------------------------------------------
diff --git a/sql/hive/src/main/scala/org/apache/spark/sql/hive/HiveQl.scala b/sql/hive/src/main/scala/org/apache/spark/sql/hive/HiveQl.scala
index 620b8a4..2f79b0a 100644
--- a/sql/hive/src/main/scala/org/apache/spark/sql/hive/HiveQl.scala
+++ b/sql/hive/src/main/scala/org/apache/spark/sql/hive/HiveQl.scala
@@ -1321,11 +1321,11 @@ https://cwiki.apache.org/confluence/display/Hive/Enhanced+Aggregation%2C+Cube%2C
/* Attribute References */
case Token("TOK_TABLE_OR_COL",
Token(name, Nil) :: Nil) =>
- UnresolvedAttribute(cleanIdentifier(name))
+ UnresolvedAttribute.quoted(cleanIdentifier(name))
case Token(".", qualifier :: Token(attr, Nil) :: Nil) =>
nodeToExpr(qualifier) match {
- case UnresolvedAttribute(qualifierName) =>
- UnresolvedAttribute(qualifierName :+ cleanIdentifier(attr))
+ case UnresolvedAttribute(nameParts) =>
+ UnresolvedAttribute(nameParts :+ cleanIdentifier(attr))
case other => UnresolvedExtractValue(other, Literal(attr))
}
http://git-wip-us.apache.org/repos/asf/spark/blob/4ffd3a1d/sql/hive/src/test/scala/org/apache/spark/sql/hive/execution/SQLQuerySuite.scala
----------------------------------------------------------------------
diff --git a/sql/hive/src/test/scala/org/apache/spark/sql/hive/execution/SQLQuerySuite.scala b/sql/hive/src/test/scala/org/apache/spark/sql/hive/execution/SQLQuerySuite.scala
index 0139363..8371dd0 100644
--- a/sql/hive/src/test/scala/org/apache/spark/sql/hive/execution/SQLQuerySuite.scala
+++ b/sql/hive/src/test/scala/org/apache/spark/sql/hive/execution/SQLQuerySuite.scala
@@ -1067,4 +1067,12 @@ class SQLQuerySuite extends QueryTest with SQLTestUtils {
)
TestHive.dropTempTable("test_SPARK8588")
}
+
+ test("SPARK-9371: fix the support for special chars in column names for hive context") {
+ TestHive.read.json(TestHive.sparkContext.makeRDD(
+ """{"a": {"c.b": 1}, "b.$q": [{"a@!.q": 1}], "q.w": {"w.i&": [1]}}""" :: Nil))
+ .registerTempTable("t")
+
+ checkAnswer(sql("SELECT a.`c.b`, `b.$q`[0].`a@!.q`, `q.w`.`w.i&`[0] FROM t"), Row(1, 1, 1))
+ }
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org