diff options
| author | wangxiaojing <u9jing@gmail.com> | 2014-12-16 14:45:56 -0800 |
|---|---|---|
| committer | Michael Armbrust <michael@databricks.com> | 2014-12-16 14:45:56 -0800 |
| commit | ea1315e3e26507c8e1cab877cec5fe69c2899ae8 (patch) | |
| tree | ae93ae337d2fecbf9dffce5ace5e16080a86ee77 /sql | |
| parent | b0dfdbdd181d1eea83d70dd0959297903952dd74 (diff) | |
| download | spark-ea1315e3e26507c8e1cab877cec5fe69c2899ae8.tar.gz spark-ea1315e3e26507c8e1cab877cec5fe69c2899ae8.tar.bz2 spark-ea1315e3e26507c8e1cab877cec5fe69c2899ae8.zip | |
[SPARK-4527][SQl]Add BroadcastNestedLoopJoin operator selection testsuite
In `JoinSuite` add BroadcastNestedLoopJoin operator selection testsuite
Author: wangxiaojing <u9jing@gmail.com>
Closes #3395 from wangxiaojing/SPARK-4527 and squashes the following commits:
ea0e495 [wangxiaojing] change style
53c3952 [wangxiaojing] Add BroadcastNestedLoopJoin operator selection testsuite
Diffstat (limited to 'sql')
| -rw-r--r-- | sql/core/src/test/scala/org/apache/spark/sql/JoinSuite.scala | 9 |
1 files changed, 7 insertions, 2 deletions
diff --git a/sql/core/src/test/scala/org/apache/spark/sql/JoinSuite.scala b/sql/core/src/test/scala/org/apache/spark/sql/JoinSuite.scala index 8b4cf5bac0..0378fd7e36 100644 --- a/sql/core/src/test/scala/org/apache/spark/sql/JoinSuite.scala +++ b/sql/core/src/test/scala/org/apache/spark/sql/JoinSuite.scala @@ -80,8 +80,13 @@ class JoinSuite extends QueryTest with BeforeAndAfterEach { classOf[HashOuterJoin]), ("SELECT * FROM testData right join testData2 ON key = a and key = 2", classOf[HashOuterJoin]), - ("SELECT * FROM testData full outer join testData2 ON key = a", classOf[HashOuterJoin]) - // TODO add BroadcastNestedLoopJoin + ("SELECT * FROM testData full outer join testData2 ON key = a", classOf[HashOuterJoin]), + ("SELECT * FROM testData left JOIN testData2 ON (key * a != key + a)", + classOf[BroadcastNestedLoopJoin]), + ("SELECT * FROM testData right JOIN testData2 ON (key * a != key + a)", + classOf[BroadcastNestedLoopJoin]), + ("SELECT * FROM testData full JOIN testData2 ON (key * a != key + a)", + classOf[BroadcastNestedLoopJoin]) ).foreach { case (query, joinClass) => assertJoin(query, joinClass) } } |