drill-commits mailing list archives

Repository: incubator-drill
Updated Branches:
  refs/heads/master 5b57294bf -> 0a3ae106e


DRILL-882 : Fix CanNotPlanException when join two different storage sources (hive vs parquet).
Code fix in Optiq.


Project: http://git-wip-us.apache.org/repos/asf/incubator-drill/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-drill/commit/0a3ae106
Tree: http://git-wip-us.apache.org/repos/asf/incubator-drill/tree/0a3ae106
Diff: http://git-wip-us.apache.org/repos/asf/incubator-drill/diff/0a3ae106

Branch: refs/heads/master
Commit: 0a3ae106e947132ac2f44cd37367f8509ff0b07a
Parents: 5b57294
Author: Jinfeng Ni <jni@maprtech.com>
Authored: Thu Jul 10 13:27:54 2014 -0700
Committer: Jinfeng Ni <jni@maprtech.com>
Committed: Thu Jul 10 13:27:54 2014 -0700

----------------------------------------------------------------------
 .../test/java/org/apache/drill/TestExampleQueries.java  | 12 +++++++++++-
 1 file changed, 11 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-drill/blob/0a3ae106/exec/java-exec/src/test/java/org/apache/drill/TestExampleQueries.java
----------------------------------------------------------------------
diff --git a/exec/java-exec/src/test/java/org/apache/drill/TestExampleQueries.java b/exec/java-exec/src/test/java/org/apache/drill/TestExampleQueries.java
index 7943756..250528f 100644
--- a/exec/java-exec/src/test/java/org/apache/drill/TestExampleQueries.java
+++ b/exec/java-exec/src/test/java/org/apache/drill/TestExampleQueries.java
@@ -38,7 +38,17 @@ public class TestExampleQueries extends BaseTestQuery{
     test("select count(*) from cp.`customer.json` limit 1");
     test("select count(*) from cp.`customer.json` limit 1");
   }
- 
+
+  @Test
+  public void testJoinExpOn() throws Exception{
+    test("select a.n_nationkey from cp.`tpch/nation.parquet` a join cp.`tpch/region.parquet`
b on a.n_regionkey + 1 = b.r_regionkey and a.n_regionkey + 1 = b.r_regionkey;");
+  }
+
+  @Test
+  public void testJoinExpWhere() throws Exception{
+    test("select a.n_nationkey from cp.`tpch/nation.parquet` a , cp.`tpch/region.parquet`
b where a.n_regionkey + 1 = b.r_regionkey and a.n_regionkey + 1 = b.r_regionkey;");
+  }
+
   @Test
   public void testCaseReturnValueVarChar() throws Exception{
     test("select case when employee_id < 1000 then 'ABC' else 'DEF' end from cp.`employee.json`
limit 5");