diff options
author | Davies Liu <davies@databricks.com> | 2016-01-06 23:46:12 -0800 |
---|---|---|
committer | Reynold Xin <rxin@databricks.com> | 2016-01-06 23:46:12 -0800 |
commit | fd1dcfaf2608c2cc3a439ed3ca044ae655982306 (patch) | |
tree | 01c77444dc5ac7cccc80447f7103dd1801e8a361 /sql/hive | |
parent | 6a1c864ab6ee3e869a16ffdbaf6fead21c7aac6d (diff) | |
download | spark-fd1dcfaf2608c2cc3a439ed3ca044ae655982306.tar.gz spark-fd1dcfaf2608c2cc3a439ed3ca044ae655982306.tar.bz2 spark-fd1dcfaf2608c2cc3a439ed3ca044ae655982306.zip |
[SPARK-12542][SQL] support except/intersect in HiveQl
Parse the SQL query with except/intersect in FROM clause for HivQL.
Author: Davies Liu <davies@databricks.com>
Closes #10622 from davies/intersect.
Diffstat (limited to 'sql/hive')
-rw-r--r-- | sql/hive/src/test/scala/org/apache/spark/sql/hive/execution/HiveQuerySuite.scala | 18 |
1 files changed, 18 insertions, 0 deletions
diff --git a/sql/hive/src/test/scala/org/apache/spark/sql/hive/execution/HiveQuerySuite.scala b/sql/hive/src/test/scala/org/apache/spark/sql/hive/execution/HiveQuerySuite.scala index 98e22c2e2c..fa99289b41 100644 --- a/sql/hive/src/test/scala/org/apache/spark/sql/hive/execution/HiveQuerySuite.scala +++ b/sql/hive/src/test/scala/org/apache/spark/sql/hive/execution/HiveQuerySuite.scala @@ -787,6 +787,24 @@ class HiveQuerySuite extends HiveComparisonTest with BeforeAndAfter { assert(sql("select key from src having key > 490").collect().size < 100) } + test("union/except/intersect") { + assertResult(Array(Row(1), Row(1))) { + sql("select 1 as a union all select 1 as a").collect() + } + assertResult(Array(Row(1))) { + sql("select 1 as a union distinct select 1 as a").collect() + } + assertResult(Array(Row(1))) { + sql("select 1 as a union select 1 as a").collect() + } + assertResult(Array()) { + sql("select 1 as a except select 1 as a").collect() + } + assertResult(Array(Row(1))) { + sql("select 1 as a intersect select 1 as a").collect() + } + } + test("SPARK-5383 alias for udfs with multi output columns") { assert( sql("select stack(2, key, value, key, value) as (a, b) from src limit 5") |