diff options
| author | Dongjoon Hyun <dongjoon@apache.org> | 2016-08-10 10:31:30 +0200 |
|---|---|---|
| committer | Herman van Hovell <hvanhovell@databricks.com> | 2016-08-10 10:31:30 +0200 |
| commit | 41a7dbdd34d2641d42eb00828f16285089356aa9 (patch) | |
| tree | cc3751488cfbd76fe6cc39a3018086dbe8c4e401 /sql/core | |
| parent | bdd537164dcfeec5e9c51d54791ef16997ff2597 (diff) | |
| download | spark-41a7dbdd34d2641d42eb00828f16285089356aa9.tar.gz spark-41a7dbdd34d2641d42eb00828f16285089356aa9.tar.bz2 spark-41a7dbdd34d2641d42eb00828f16285089356aa9.zip | |
[SPARK-10601][SQL] Support `MINUS` set operator
## What changes were proposed in this pull request?
This PR adds `MINUS` set operator which is equivalent `EXCEPT DISTINCT`. This will slightly improve the compatibility with Oracle.
## How was this patch tested?
Pass the Jenkins with newly added testcases.
Author: Dongjoon Hyun <dongjoon@apache.org>
Closes #14570 from dongjoon-hyun/SPARK-10601.
Diffstat (limited to 'sql/core')
| -rw-r--r-- | sql/core/src/test/scala/org/apache/spark/sql/SQLQuerySuite.scala | 10 |
1 files changed, 10 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 8e7c8d7f07..4ba324aa8c 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 @@ -1103,6 +1103,16 @@ class SQLQuerySuite extends QueryTest with SharedSQLContext { sql("SELECT * FROM upperCaseData EXCEPT SELECT * FROM upperCaseData"), Nil) } + test("MINUS") { + checkAnswer( + sql("SELECT * FROM lowerCaseData MINUS SELECT * FROM upperCaseData"), + Row(1, "a") :: Row(2, "b") :: Row(3, "c") :: Row(4, "d") :: Nil) + checkAnswer( + sql("SELECT * FROM lowerCaseData MINUS SELECT * FROM lowerCaseData"), Nil) + checkAnswer( + sql("SELECT * FROM upperCaseData MINUS SELECT * FROM upperCaseData"), Nil) + } + test("INTERSECT") { checkAnswer( sql("SELECT * FROM lowerCaseData INTERSECT SELECT * FROM lowerCaseData"), |