aboutsummaryrefslogtreecommitdiff
path: root/sql/core
diff options
context:
space:
mode:
authorhaiyang <huhaiyang@huawei.com>2015-04-11 18:30:17 -0700
committerMichael Armbrust <michael@databricks.com>2015-04-11 18:30:17 -0700
commit2f53588738e95a2191f9844818e47f0d2ebbfd54 (patch)
tree2cdb58ec4161ee4d5d2e191ea10d8653c6878a8d /sql/core
parent7dbd37160ff57f80cc7abdcaef95f8c6df20a0f0 (diff)
downloadspark-2f53588738e95a2191f9844818e47f0d2ebbfd54.tar.gz
spark-2f53588738e95a2191f9844818e47f0d2ebbfd54.tar.bz2
spark-2f53588738e95a2191f9844818e47f0d2ebbfd54.zip
[SPARK-6199] [SQL] Support CTE in HiveContext and SQLContext
Author: haiyang <huhaiyang@huawei.com> Closes #4929 from haiyangsea/cte and squashes the following commits: 220b67d [haiyang] add golden files for cte test d3c7681 [haiyang] Merge branch 'master' into cte-repair 0ba2070 [haiyang] modify code style 9ce6b58 [haiyang] fix conflict ff74741 [haiyang] add comment for With plan 0d56af4 [haiyang] code indention 776a440 [haiyang] add comments for resolve relation strategy 2fccd7e [haiyang] add comments for resolve relation strategy 241bbe2 [haiyang] fix cte problem of view e9e1237 [haiyang] fix test case problem 614182f [haiyang] add test cases for CTE feature 32e415b [haiyang] add comment 1cc8c15 [haiyang] support with 03f1097 [haiyang] support with e960099 [haiyang] support with 9aaa874 [haiyang] support with 0566978 [haiyang] support with a99ecd2 [haiyang] support with c3fa4c2 [haiyang] support with 3b6077f [haiyang] support with 5f8abe3 [haiyang] support with 4572b05 [haiyang] support with f801f54 [haiyang] support with
Diffstat (limited to 'sql/core')
-rw-r--r--sql/core/src/test/scala/org/apache/spark/sql/SQLQuerySuite.scala14
1 files changed, 14 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 1392b48191..fb8fc6dbd1 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
@@ -407,6 +407,20 @@ class SQLQuerySuite extends QueryTest with BeforeAndAfterAll {
mapData.collect().take(1).map(Row.fromTuple).toSeq)
}
+ test("CTE feature") {
+ checkAnswer(
+ sql("with q1 as (select * from testData limit 10) select * from q1"),
+ testData.take(10).toSeq)
+
+ checkAnswer(
+ sql("""
+ |with q1 as (select * from testData where key= '5'),
+ |q2 as (select * from testData where key = '4')
+ |select * from q1 union all select * from q2""".stripMargin),
+ Row(5, "5") :: Row(4, "4") :: Nil)
+
+ }
+
test("date row") {
checkAnswer(sql(
"""select cast("2015-01-28" as date) from testData limit 1"""),