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 <j...@maprtech.com> Authored: Thu Jul 10 13:27:54 2014 -0700 Committer: Jinfeng Ni <j...@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");
