aboutsummaryrefslogtreecommitdiff
path: root/sql/core
diff options
context:
space:
mode:
authorjerryshao <saisai.shao@intel.com>2014-03-30 10:03:58 -0700
committerPatrick Wendell <pwendell@gmail.com>2014-03-30 10:04:28 -0700
commit95d7d2a3fc2adc0bbca90d015c6ca319fffb26aa (patch)
tree67f21ae7e2d4dc07c6e16c59cc3a0f7f9d70c1f8 /sql/core
parentdf1b9f7b1a07bf8d806695a7684f9d69bf705093 (diff)
downloadspark-95d7d2a3fc2adc0bbca90d015c6ca319fffb26aa.tar.gz
spark-95d7d2a3fc2adc0bbca90d015c6ca319fffb26aa.tar.bz2
spark-95d7d2a3fc2adc0bbca90d015c6ca319fffb26aa.zip
[SPARK-1354][SQL] Add tableName as a qualifier for SimpleCatelogy
Fix attribute unresolved when query with table name as a qualifier in SQLContext with SimplCatelog, details please see [SPARK-1354](https://issues.apache.org/jira/browse/SPARK-1354?jql=project%20%3D%20SPARK). Author: jerryshao <saisai.shao@intel.com> Closes #272 from jerryshao/qualifier-fix and squashes the following commits: 7950170 [jerryshao] Add tableName as a qualifier for SimpleCatelogy
Diffstat (limited to 'sql/core')
-rw-r--r--sql/core/src/test/scala/org/apache/spark/sql/SQLQuerySuite.scala27
1 files changed, 27 insertions, 0 deletions
diff --git a/sql/core/src/test/scala/org/apache/spark/sql/SQLQuerySuite.scala b/sql/core/src/test/scala/org/apache/spark/sql/SQLQuerySuite.scala
index fa4a1d5189..4c4fd6dbbe 100644
--- a/sql/core/src/test/scala/org/apache/spark/sql/SQLQuerySuite.scala
+++ b/sql/core/src/test/scala/org/apache/spark/sql/SQLQuerySuite.scala
@@ -216,4 +216,31 @@ class SQLQuerySuite extends QueryTest {
(null, null, 5, "E") ::
(null, null, 6, "F") :: Nil)
}
+
+ test("select with table name as qualifier") {
+ checkAnswer(
+ sql("SELECT testData.value FROM testData WHERE testData.key = 1"),
+ Seq(Seq("1")))
+ }
+
+ test("inner join ON with table name as qualifier") {
+ checkAnswer(
+ sql("SELECT * FROM upperCaseData JOIN lowerCaseData ON lowerCaseData.n = upperCaseData.N"),
+ Seq(
+ (1, "A", 1, "a"),
+ (2, "B", 2, "b"),
+ (3, "C", 3, "c"),
+ (4, "D", 4, "d")))
+ }
+
+ test("qualified select with inner join ON with table name as qualifier") {
+ checkAnswer(
+ sql("SELECT upperCaseData.N, upperCaseData.L FROM upperCaseData JOIN lowerCaseData " +
+ "ON lowerCaseData.n = upperCaseData.N"),
+ Seq(
+ (1, "A"),
+ (2, "B"),
+ (3, "C"),
+ (4, "D")))
+ }
}