TAJO-1845: Enforcers in the master plan should be printed in a fixed order.
Project: http://git-wip-us.apache.org/repos/asf/tajo/repo Commit: http://git-wip-us.apache.org/repos/asf/tajo/commit/f1cf1a24 Tree: http://git-wip-us.apache.org/repos/asf/tajo/tree/f1cf1a24 Diff: http://git-wip-us.apache.org/repos/asf/tajo/diff/f1cf1a24 Branch: refs/heads/branch-0.11.0 Commit: f1cf1a2421b1d613a24a0769895b1acdaed3f449 Parents: 4b92376 Author: Jihoon Son <[email protected]> Authored: Sun Sep 13 14:40:14 2015 +0900 Committer: Jihoon Son <[email protected]> Committed: Sun Sep 13 14:40:14 2015 +0900 ---------------------------------------------------------------------- CHANGES | 3 + .../tajo/engine/query/TestInnerJoinQuery.java | 4 +- .../engine/query/TestInnerJoinWithSubQuery.java | 8 +- .../TestJoinQuery/testComplexJoinCondition5.sql | 2 +- ...stCrossJoinWithThetaJoinConditionInWhere.sql | 2 +- ...stInnerJoinWithThetaJoinConditionInWhere.sql | 6 +- ...tCrossJoinOfOneSmallTableAndJoin.1.Hash.plan | 4 +- ...tCrossJoinOfOneSmallTableAndJoin.1.Sort.plan | 4 +- ...sJoinWithThetaJoinConditionInWhere.Hash.plan | 36 +++--- ...taJoinConditionInWhere.Hash_NoBroadcast.plan | 40 +++---- ...sJoinWithThetaJoinConditionInWhere.Sort.plan | 36 +++--- ...taJoinConditionInWhere.Sort_NoBroadcast.plan | 40 +++---- ...rossJoinWithThetaJoinConditionInWhere.result | 109 +++++++++++++++++-- .../testBroadcastTwoPartJoin.Hash.plan | 8 +- .../testBroadcastTwoPartJoin.Sort.plan | 8 +- .../testDifferentTypesJoinCondition.Hash.plan | 2 +- .../testDifferentTypesJoinCondition.Sort.plan | 2 +- .../testDifferentTypesJoinCondition.result | 7 +- ...rJoinWithThetaJoinConditionInWhere.Hash.plan | 36 +++--- ...taJoinConditionInWhere.Hash_NoBroadcast.plan | 44 ++++---- ...rJoinWithThetaJoinConditionInWhere.Sort.plan | 36 +++--- ...taJoinConditionInWhere.Sort_NoBroadcast.plan | 44 ++++---- ...nnerJoinWithThetaJoinConditionInWhere.result | 28 ++++- .../testJoinOnMultipleDatabases.Hash.plan | 8 +- .../testJoinOnMultipleDatabases.Sort.plan | 8 +- .../testJoinWithMultipleJoinQual1.Hash.plan | 8 +- .../testJoinWithMultipleJoinQual1.Sort.plan | 8 +- .../TestInnerJoinQuery/testTPCHQ2Join.Hash.plan | 6 +- .../TestInnerJoinQuery/testTPCHQ2Join.Sort.plan | 6 +- .../testWhereClauseJoin5.Hash.plan | 4 +- .../testWhereClauseJoin5.Sort.plan | 4 +- .../testWhereClauseJoin6.Hash.plan | 4 +- .../testWhereClauseJoin6.Sort.plan | 4 +- .../testBroadcastSubquery.Hash.plan | 4 +- .../testBroadcastSubquery.Sort.plan | 4 +- .../testBroadcastSubquery2.Hash.plan | 6 +- .../testBroadcastSubquery2.Sort.plan | 6 +- .../testComplexJoinCondition5.Hash.plan | 40 +++---- ...tComplexJoinCondition5.Hash_NoBroadcast.plan | 62 +++++------ .../testComplexJoinCondition5.Sort.plan | 40 +++---- ...tComplexJoinCondition5.Sort_NoBroadcast.plan | 62 +++++------ .../testComplexJoinCondition5.result | 22 ---- .../testComplexJoinCondition6.Hash.plan | 4 +- .../testComplexJoinCondition6.Sort.plan | 4 +- .../testComplexJoinCondition7.Hash.plan | 4 +- .../testComplexJoinCondition7.Sort.plan | 4 +- .../testJoinWithMultipleJoinQual3.Hash.plan | 4 +- .../testJoinWithMultipleJoinQual3.Sort.plan | 4 +- .../testJoinWithMultipleJoinQual4.Hash.plan | 4 +- .../testJoinWithMultipleJoinQual4.Sort.plan | 4 +- .../testComplexJoinsWithCaseWhen2.Hash.plan | 4 +- .../testComplexJoinsWithCaseWhen2.Sort.plan | 4 +- .../testLeftOuterJoin3.Hash.plan | 8 +- .../testLeftOuterJoin3.Sort.plan | 8 +- ...tOuterJoinPredicationCaseByCase2.1.Hash.plan | 4 +- ...tOuterJoinPredicationCaseByCase2.1.Sort.plan | 4 +- ...uterJoinPredicationCaseByCase2_1.1.Hash.plan | 4 +- ...uterJoinPredicationCaseByCase2_1.1.Sort.plan | 4 +- ...tOuterJoinPredicationCaseByCase1.1.Hash.plan | 4 +- ...tOuterJoinPredicationCaseByCase1.1.Sort.plan | 4 +- ...tOuterJoinPredicationCaseByCase2.1.Hash.plan | 4 +- ...tOuterJoinPredicationCaseByCase2.1.Sort.plan | 4 +- ...tOuterJoinPredicationCaseByCase3.1.Hash.plan | 4 +- ...tOuterJoinPredicationCaseByCase3.1.Sort.plan | 4 +- ...tLeftOuterJoinWithEmptySubquery2.1.Hash.plan | 4 +- ...tLeftOuterJoinWithEmptySubquery2.1.Sort.plan | 4 +- .../tajo/engine/planner/enforce/Enforcer.java | 7 +- .../tajo/engine/planner/global/MasterPlan.java | 14 ++- 68 files changed, 516 insertions(+), 424 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/tajo/blob/f1cf1a24/CHANGES ---------------------------------------------------------------------- diff --git a/CHANGES b/CHANGES index 4488aa2..13ae486 100644 --- a/CHANGES +++ b/CHANGES @@ -534,6 +534,9 @@ Release 0.11.0 - unreleased TASKS + TAJO-1845: Enforcers in the master plan should be printed in a fixed + order.(jihoon) + TAJO-1739: Add a statement for adding partition to TajoDump. (jaehwa) TAJO-1833: Refine LogicalPlanPreprocessor to add new rules easily. http://git-wip-us.apache.org/repos/asf/tajo/blob/f1cf1a24/tajo-core-tests/src/test/java/org/apache/tajo/engine/query/TestInnerJoinQuery.java ---------------------------------------------------------------------- diff --git a/tajo-core-tests/src/test/java/org/apache/tajo/engine/query/TestInnerJoinQuery.java b/tajo-core-tests/src/test/java/org/apache/tajo/engine/query/TestInnerJoinQuery.java index 6ec828c..1a76f57 100644 --- a/tajo-core-tests/src/test/java/org/apache/tajo/engine/query/TestInnerJoinQuery.java +++ b/tajo-core-tests/src/test/java/org/apache/tajo/engine/query/TestInnerJoinQuery.java @@ -50,7 +50,7 @@ public class TestInnerJoinQuery extends TestJoinQuery { } @Test - @Option(withExplain = true, withExplainGlobal = true, parameterized = true) + @Option(withExplain = true, withExplainGlobal = true, parameterized = true, sort = true) @SimpleTest() public final void testInnerJoinWithThetaJoinConditionInWhere() throws Exception { runSimpleTests(); @@ -204,7 +204,7 @@ public class TestInnerJoinQuery extends TestJoinQuery { public void testDifferentTypesJoinCondition() throws Exception { // select * from table20 t3 join table21 t4 on t3.id = t4.id; executeDDL("table1_int8_ddl.sql", "table1", "table20"); - executeDDL("table1_int4_ddl.sql", "table1", "table21"); + executeDDL("table1_int4_ddl.sql", "table2", "table21"); try { runSimpleTests(); } finally { http://git-wip-us.apache.org/repos/asf/tajo/blob/f1cf1a24/tajo-core-tests/src/test/java/org/apache/tajo/engine/query/TestInnerJoinWithSubQuery.java ---------------------------------------------------------------------- diff --git a/tajo-core-tests/src/test/java/org/apache/tajo/engine/query/TestInnerJoinWithSubQuery.java b/tajo-core-tests/src/test/java/org/apache/tajo/engine/query/TestInnerJoinWithSubQuery.java index 6c9546e..f987c5f 100644 --- a/tajo-core-tests/src/test/java/org/apache/tajo/engine/query/TestInnerJoinWithSubQuery.java +++ b/tajo-core-tests/src/test/java/org/apache/tajo/engine/query/TestInnerJoinWithSubQuery.java @@ -90,7 +90,13 @@ public class TestInnerJoinWithSubQuery extends TestJoinQuery { @Test @Option(withExplain = true, withExplainGlobal = true, parameterized = true) - @SimpleTest() + @SimpleTest( + prepare = { + "create table small_nation as select * from nation limit 5;" + }, + cleanup = { + "drop table small_nation purge;" + }) public void testComplexJoinCondition5() throws Exception { runSimpleTests(); } http://git-wip-us.apache.org/repos/asf/tajo/blob/f1cf1a24/tajo-core-tests/src/test/resources/queries/TestJoinQuery/testComplexJoinCondition5.sql ---------------------------------------------------------------------- diff --git a/tajo-core-tests/src/test/resources/queries/TestJoinQuery/testComplexJoinCondition5.sql b/tajo-core-tests/src/test/resources/queries/TestJoinQuery/testComplexJoinCondition5.sql index f604bc7..a3d2f3e 100644 --- a/tajo-core-tests/src/test/resources/queries/TestJoinQuery/testComplexJoinCondition5.sql +++ b/tajo-core-tests/src/test/resources/queries/TestJoinQuery/testComplexJoinCondition5.sql @@ -2,5 +2,5 @@ select n1.n_nationkey, substr(n1.n_name, 1, 4) name1, substr(n2.n_name, 1, 4) name2 -from nation n1 join (select * from nation) n2 on substr(n1.n_name, 1, 4) = substr(n2.n_name, 1, 4) +from nation n1 join (select * from small_nation) n2 on substr(n1.n_name, 1, 4) = substr(n2.n_name, 1, 4) order by n1.n_nationkey; \ No newline at end of file http://git-wip-us.apache.org/repos/asf/tajo/blob/f1cf1a24/tajo-core-tests/src/test/resources/queries/TestJoinQuery/testCrossJoinWithThetaJoinConditionInWhere.sql ---------------------------------------------------------------------- diff --git a/tajo-core-tests/src/test/resources/queries/TestJoinQuery/testCrossJoinWithThetaJoinConditionInWhere.sql b/tajo-core-tests/src/test/resources/queries/TestJoinQuery/testCrossJoinWithThetaJoinConditionInWhere.sql index 4e20e16..e0ae358 100644 --- a/tajo-core-tests/src/test/resources/queries/TestJoinQuery/testCrossJoinWithThetaJoinConditionInWhere.sql +++ b/tajo-core-tests/src/test/resources/queries/TestJoinQuery/testCrossJoinWithThetaJoinConditionInWhere.sql @@ -1,2 +1,2 @@ -select a.r_name as a_name, b.r_name as b_name from region a, region b +select a.r_name as a_name, b.n_name as b_name from region a, nation b where a_name < b_name; \ No newline at end of file http://git-wip-us.apache.org/repos/asf/tajo/blob/f1cf1a24/tajo-core-tests/src/test/resources/queries/TestJoinQuery/testInnerJoinWithThetaJoinConditionInWhere.sql ---------------------------------------------------------------------- diff --git a/tajo-core-tests/src/test/resources/queries/TestJoinQuery/testInnerJoinWithThetaJoinConditionInWhere.sql b/tajo-core-tests/src/test/resources/queries/TestJoinQuery/testInnerJoinWithThetaJoinConditionInWhere.sql index 90f4822..ff679d5 100644 --- a/tajo-core-tests/src/test/resources/queries/TestJoinQuery/testInnerJoinWithThetaJoinConditionInWhere.sql +++ b/tajo-core-tests/src/test/resources/queries/TestJoinQuery/testInnerJoinWithThetaJoinConditionInWhere.sql @@ -1,3 +1,3 @@ -select a.r_regionkey, a.r_name, b.r_name from region a join region b -on a.r_regionkey = b.r_regionkey -where a.r_name <= b.r_name; \ No newline at end of file +select a.r_regionkey, a.r_name, b.n_name from region a join nation b +on a.r_regionkey = b.n_regionkey +where a.r_name <= b.n_name; \ No newline at end of file http://git-wip-us.apache.org/repos/asf/tajo/blob/f1cf1a24/tajo-core-tests/src/test/resources/results/TestCrossJoin/testCrossJoinOfOneSmallTableAndJoin.1.Hash.plan ---------------------------------------------------------------------- diff --git a/tajo-core-tests/src/test/resources/results/TestCrossJoin/testCrossJoinOfOneSmallTableAndJoin.1.Hash.plan b/tajo-core-tests/src/test/resources/results/TestCrossJoin/testCrossJoinOfOneSmallTableAndJoin.1.Hash.plan index 54d2e62..36a1b43 100644 --- a/tajo-core-tests/src/test/resources/results/TestCrossJoin/testCrossJoinOfOneSmallTableAndJoin.1.Hash.plan +++ b/tajo-core-tests/src/test/resources/results/TestCrossJoin/testCrossJoinOfOneSmallTableAndJoin.1.Hash.plan @@ -49,9 +49,9 @@ Block Id: eb_0000000000000_0000_000007 [ROOT] ======================================================= [Enforcers] - 0: type=Broadcast, tables=default.supplier + 0: type=Broadcast, tables=default.orders 1: type=Broadcast, tables=default.region - 2: type=Broadcast, tables=default.orders + 2: type=Broadcast, tables=default.supplier JOIN(11)(CROSS) => target list: default.lineitem.l_comment (TEXT), default.lineitem.l_commitdate (TEXT), default.lineitem.l_discount (FLOAT8), default.lineitem.l_extendedprice (FLOAT8), default.lineitem.l_linenumber (INT4), default.lineitem.l_linestatus (TEXT), default.lineitem.l_orderkey (INT4), default.lineitem.l_partkey (INT4), default.lineitem.l_quantity (FLOAT8), default.lineitem.l_receiptdate (TEXT), default.lineitem.l_returnflag (TEXT), default.lineitem.l_shipdate (TEXT), default.lineitem.l_shipinstruct (TEXT), default.lineitem.l_shipmode (TEXT), default.lineitem.l_suppkey (INT4), default.lineitem.l_tax (FLOAT8), default.orders.o_clerk (TEXT), default.orders.o_comment (TEXT), default.orders.o_custkey (INT4), default.orders.o_orderdate (TEXT), default.orders.o_orderkey (INT4), default.orders.o_orderpriority (TEXT), default.orders.o_orderstatus (TEXT), default.orders.o_shippriority (INT4), default.orders.o_totalprice (FLOAT8), default.region.r_comment (TEXT), default.region.r_name (TEXT), de fault.region.r_regionkey (INT4), default.supplier.s_acctbal (FLOAT8), default.supplier.s_address (TEXT), default.supplier.s_comment (TEXT), default.supplier.s_name (TEXT), default.supplier.s_nationkey (INT4), default.supplier.s_phone (TEXT), default.supplier.s_suppkey (INT4) http://git-wip-us.apache.org/repos/asf/tajo/blob/f1cf1a24/tajo-core-tests/src/test/resources/results/TestCrossJoin/testCrossJoinOfOneSmallTableAndJoin.1.Sort.plan ---------------------------------------------------------------------- diff --git a/tajo-core-tests/src/test/resources/results/TestCrossJoin/testCrossJoinOfOneSmallTableAndJoin.1.Sort.plan b/tajo-core-tests/src/test/resources/results/TestCrossJoin/testCrossJoinOfOneSmallTableAndJoin.1.Sort.plan index 54d2e62..36a1b43 100644 --- a/tajo-core-tests/src/test/resources/results/TestCrossJoin/testCrossJoinOfOneSmallTableAndJoin.1.Sort.plan +++ b/tajo-core-tests/src/test/resources/results/TestCrossJoin/testCrossJoinOfOneSmallTableAndJoin.1.Sort.plan @@ -49,9 +49,9 @@ Block Id: eb_0000000000000_0000_000007 [ROOT] ======================================================= [Enforcers] - 0: type=Broadcast, tables=default.supplier + 0: type=Broadcast, tables=default.orders 1: type=Broadcast, tables=default.region - 2: type=Broadcast, tables=default.orders + 2: type=Broadcast, tables=default.supplier JOIN(11)(CROSS) => target list: default.lineitem.l_comment (TEXT), default.lineitem.l_commitdate (TEXT), default.lineitem.l_discount (FLOAT8), default.lineitem.l_extendedprice (FLOAT8), default.lineitem.l_linenumber (INT4), default.lineitem.l_linestatus (TEXT), default.lineitem.l_orderkey (INT4), default.lineitem.l_partkey (INT4), default.lineitem.l_quantity (FLOAT8), default.lineitem.l_receiptdate (TEXT), default.lineitem.l_returnflag (TEXT), default.lineitem.l_shipdate (TEXT), default.lineitem.l_shipinstruct (TEXT), default.lineitem.l_shipmode (TEXT), default.lineitem.l_suppkey (INT4), default.lineitem.l_tax (FLOAT8), default.orders.o_clerk (TEXT), default.orders.o_comment (TEXT), default.orders.o_custkey (INT4), default.orders.o_orderdate (TEXT), default.orders.o_orderkey (INT4), default.orders.o_orderpriority (TEXT), default.orders.o_orderstatus (TEXT), default.orders.o_shippriority (INT4), default.orders.o_totalprice (FLOAT8), default.region.r_comment (TEXT), default.region.r_name (TEXT), de fault.region.r_regionkey (INT4), default.supplier.s_acctbal (FLOAT8), default.supplier.s_address (TEXT), default.supplier.s_comment (TEXT), default.supplier.s_name (TEXT), default.supplier.s_nationkey (INT4), default.supplier.s_phone (TEXT), default.supplier.s_suppkey (INT4) http://git-wip-us.apache.org/repos/asf/tajo/blob/f1cf1a24/tajo-core-tests/src/test/resources/results/TestCrossJoin/testCrossJoinWithThetaJoinConditionInWhere.Hash.plan ---------------------------------------------------------------------- diff --git a/tajo-core-tests/src/test/resources/results/TestCrossJoin/testCrossJoinWithThetaJoinConditionInWhere.Hash.plan b/tajo-core-tests/src/test/resources/results/TestCrossJoin/testCrossJoinWithThetaJoinConditionInWhere.Hash.plan index d161811..6ec39f9 100644 --- a/tajo-core-tests/src/test/resources/results/TestCrossJoin/testCrossJoinWithThetaJoinConditionInWhere.Hash.plan +++ b/tajo-core-tests/src/test/resources/results/TestCrossJoin/testCrossJoinWithThetaJoinConditionInWhere.Hash.plan @@ -3,21 +3,21 @@ explain PROJECTION(3) => Targets: a_name (TEXT), b_name (TEXT) => out schema: {(2) a_name (TEXT), b_name (TEXT)} - => in schema: {(4) a_name (TEXT), b_name (TEXT), default.a.r_name (TEXT), default.b.r_name (TEXT)} + => in schema: {(4) a_name (TEXT), b_name (TEXT), default.a.r_name (TEXT), default.b.n_name (TEXT)} SELECTION(6) - => Search Cond: default.a.r_name (TEXT) < default.b.r_name (TEXT) + => Search Cond: default.a.r_name (TEXT) < default.b.n_name (TEXT) JOIN(7)(CROSS) - => target list: a_name (TEXT), b_name (TEXT), default.a.r_name (TEXT), default.b.r_name (TEXT) - => out schema: {(4) a_name (TEXT), b_name (TEXT), default.a.r_name (TEXT), default.b.r_name (TEXT)} - => in schema: {(4) a_name (TEXT), b_name (TEXT), default.a.r_name (TEXT), default.b.r_name (TEXT)} + => target list: a_name (TEXT), b_name (TEXT), default.a.r_name (TEXT), default.b.n_name (TEXT) + => out schema: {(4) a_name (TEXT), b_name (TEXT), default.a.r_name (TEXT), default.b.n_name (TEXT)} + => in schema: {(4) a_name (TEXT), b_name (TEXT), default.a.r_name (TEXT), default.b.n_name (TEXT)} SCAN(0) on default.region as a => target list: default.a.r_name (TEXT) as a_name, default.a.r_name (TEXT) => out schema: {(2) a_name (TEXT), default.a.r_name (TEXT)} => in schema: {(3) default.a.r_comment (TEXT), default.a.r_name (TEXT), default.a.r_regionkey (INT4)} - SCAN(1) on default.region as b - => target list: default.b.r_name (TEXT) as b_name, default.b.r_name (TEXT) - => out schema: {(2) b_name (TEXT), default.b.r_name (TEXT)} - => in schema: {(3) default.b.r_comment (TEXT), default.b.r_name (TEXT), default.b.r_regionkey (INT4)} + SCAN(1) on default.nation as b + => target list: default.b.n_name (TEXT) as b_name, default.b.n_name (TEXT) + => out schema: {(2) b_name (TEXT), default.b.n_name (TEXT)} + => in schema: {(4) default.b.n_comment (TEXT), default.b.n_name (TEXT), default.b.n_nationkey (INT4), default.b.n_regionkey (INT4)} explain ------------------------------- ------------------------------------------------------------------------------- @@ -42,21 +42,21 @@ Block Id: eb_0000000000000_0000_000003 [ROOT] PROJECTION(3) => Targets: a_name (TEXT), b_name (TEXT) => out schema: {(2) a_name (TEXT), b_name (TEXT)} - => in schema: {(4) a_name (TEXT), b_name (TEXT), default.a.r_name (TEXT), default.b.r_name (TEXT)} + => in schema: {(4) a_name (TEXT), b_name (TEXT), default.a.r_name (TEXT), default.b.n_name (TEXT)} SELECTION(6) - => Search Cond: default.a.r_name (TEXT) < default.b.r_name (TEXT) + => Search Cond: default.a.r_name (TEXT) < default.b.n_name (TEXT) JOIN(7)(CROSS) - => target list: a_name (TEXT), b_name (TEXT), default.a.r_name (TEXT), default.b.r_name (TEXT) - => out schema: {(4) a_name (TEXT), b_name (TEXT), default.a.r_name (TEXT), default.b.r_name (TEXT)} - => in schema: {(4) a_name (TEXT), b_name (TEXT), default.a.r_name (TEXT), default.b.r_name (TEXT)} + => target list: a_name (TEXT), b_name (TEXT), default.a.r_name (TEXT), default.b.n_name (TEXT) + => out schema: {(4) a_name (TEXT), b_name (TEXT), default.a.r_name (TEXT), default.b.n_name (TEXT)} + => in schema: {(4) a_name (TEXT), b_name (TEXT), default.a.r_name (TEXT), default.b.n_name (TEXT)} SCAN(0) on default.region as a => target list: default.a.r_name (TEXT) as a_name, default.a.r_name (TEXT) => out schema: {(2) a_name (TEXT), default.a.r_name (TEXT)} => in schema: {(3) default.a.r_comment (TEXT), default.a.r_name (TEXT), default.a.r_regionkey (INT4)} - SCAN(1) on default.region as b - => target list: default.b.r_name (TEXT) as b_name, default.b.r_name (TEXT) - => out schema: {(2) b_name (TEXT), default.b.r_name (TEXT)} - => in schema: {(3) default.b.r_comment (TEXT), default.b.r_name (TEXT), default.b.r_regionkey (INT4)} + SCAN(1) on default.nation as b + => target list: default.b.n_name (TEXT) as b_name, default.b.n_name (TEXT) + => out schema: {(2) b_name (TEXT), default.b.n_name (TEXT)} + => in schema: {(4) default.b.n_comment (TEXT), default.b.n_name (TEXT), default.b.n_nationkey (INT4), default.b.n_regionkey (INT4)} ======================================================= Block Id: eb_0000000000000_0000_000004 [TERMINAL] http://git-wip-us.apache.org/repos/asf/tajo/blob/f1cf1a24/tajo-core-tests/src/test/resources/results/TestCrossJoin/testCrossJoinWithThetaJoinConditionInWhere.Hash_NoBroadcast.plan ---------------------------------------------------------------------- diff --git a/tajo-core-tests/src/test/resources/results/TestCrossJoin/testCrossJoinWithThetaJoinConditionInWhere.Hash_NoBroadcast.plan b/tajo-core-tests/src/test/resources/results/TestCrossJoin/testCrossJoinWithThetaJoinConditionInWhere.Hash_NoBroadcast.plan index cfbfa19..fd89830 100644 --- a/tajo-core-tests/src/test/resources/results/TestCrossJoin/testCrossJoinWithThetaJoinConditionInWhere.Hash_NoBroadcast.plan +++ b/tajo-core-tests/src/test/resources/results/TestCrossJoin/testCrossJoinWithThetaJoinConditionInWhere.Hash_NoBroadcast.plan @@ -3,21 +3,21 @@ explain PROJECTION(3) => Targets: a_name (TEXT), b_name (TEXT) => out schema: {(2) a_name (TEXT), b_name (TEXT)} - => in schema: {(4) a_name (TEXT), b_name (TEXT), default.a.r_name (TEXT), default.b.r_name (TEXT)} + => in schema: {(4) a_name (TEXT), b_name (TEXT), default.a.r_name (TEXT), default.b.n_name (TEXT)} SELECTION(6) - => Search Cond: default.a.r_name (TEXT) < default.b.r_name (TEXT) + => Search Cond: default.a.r_name (TEXT) < default.b.n_name (TEXT) JOIN(7)(CROSS) - => target list: a_name (TEXT), b_name (TEXT), default.a.r_name (TEXT), default.b.r_name (TEXT) - => out schema: {(4) a_name (TEXT), b_name (TEXT), default.a.r_name (TEXT), default.b.r_name (TEXT)} - => in schema: {(4) a_name (TEXT), b_name (TEXT), default.a.r_name (TEXT), default.b.r_name (TEXT)} + => target list: a_name (TEXT), b_name (TEXT), default.a.r_name (TEXT), default.b.n_name (TEXT) + => out schema: {(4) a_name (TEXT), b_name (TEXT), default.a.r_name (TEXT), default.b.n_name (TEXT)} + => in schema: {(4) a_name (TEXT), b_name (TEXT), default.a.r_name (TEXT), default.b.n_name (TEXT)} SCAN(0) on default.region as a => target list: default.a.r_name (TEXT) as a_name, default.a.r_name (TEXT) => out schema: {(2) a_name (TEXT), default.a.r_name (TEXT)} => in schema: {(3) default.a.r_comment (TEXT), default.a.r_name (TEXT), default.a.r_regionkey (INT4)} - SCAN(1) on default.region as b - => target list: default.b.r_name (TEXT) as b_name, default.b.r_name (TEXT) - => out schema: {(2) b_name (TEXT), default.b.r_name (TEXT)} - => in schema: {(3) default.b.r_comment (TEXT), default.b.r_name (TEXT), default.b.r_regionkey (INT4)} + SCAN(1) on default.nation as b + => target list: default.b.n_name (TEXT) as b_name, default.b.n_name (TEXT) + => out schema: {(2) b_name (TEXT), default.b.n_name (TEXT)} + => in schema: {(4) default.b.n_comment (TEXT), default.b.n_name (TEXT), default.b.n_nationkey (INT4), default.b.n_regionkey (INT4)} explain ------------------------------- ------------------------------------------------------------------------------- @@ -43,10 +43,10 @@ Block Id: eb_0000000000000_0000_000001 [LEAF] [Outgoing] [q_0000000000000_0000] 1 => 3 (type=HASH_SHUFFLE) -SCAN(1) on default.region as b - => target list: default.b.r_name (TEXT) as b_name, default.b.r_name (TEXT) - => out schema: {(2) b_name (TEXT), default.b.r_name (TEXT)} - => in schema: {(3) default.b.r_comment (TEXT), default.b.r_name (TEXT), default.b.r_regionkey (INT4)} +SCAN(1) on default.nation as b + => target list: default.b.n_name (TEXT) as b_name, default.b.n_name (TEXT) + => out schema: {(2) b_name (TEXT), default.b.n_name (TEXT)} + => in schema: {(4) default.b.n_comment (TEXT), default.b.n_name (TEXT), default.b.n_nationkey (INT4), default.b.n_regionkey (INT4)} ======================================================= Block Id: eb_0000000000000_0000_000002 [LEAF] @@ -71,19 +71,19 @@ Block Id: eb_0000000000000_0000_000003 [ROOT] PROJECTION(3) => Targets: a_name (TEXT), b_name (TEXT) => out schema: {(2) a_name (TEXT), b_name (TEXT)} - => in schema: {(4) a_name (TEXT), b_name (TEXT), default.a.r_name (TEXT), default.b.r_name (TEXT)} + => in schema: {(4) a_name (TEXT), b_name (TEXT), default.a.r_name (TEXT), default.b.n_name (TEXT)} SELECTION(6) - => Search Cond: default.a.r_name (TEXT) < default.b.r_name (TEXT) + => Search Cond: default.a.r_name (TEXT) < default.b.n_name (TEXT) JOIN(7)(CROSS) - => target list: a_name (TEXT), b_name (TEXT), default.a.r_name (TEXT), default.b.r_name (TEXT) - => out schema: {(4) a_name (TEXT), b_name (TEXT), default.a.r_name (TEXT), default.b.r_name (TEXT)} - => in schema: {(4) a_name (TEXT), b_name (TEXT), default.a.r_name (TEXT), default.b.r_name (TEXT)} + => target list: a_name (TEXT), b_name (TEXT), default.a.r_name (TEXT), default.b.n_name (TEXT) + => out schema: {(4) a_name (TEXT), b_name (TEXT), default.a.r_name (TEXT), default.b.n_name (TEXT)} + => in schema: {(4) a_name (TEXT), b_name (TEXT), default.a.r_name (TEXT), default.b.n_name (TEXT)} SCAN(10) on eb_0000000000000_0000_000002 => out schema: {(2) a_name (TEXT), default.a.r_name (TEXT)} => in schema: {(2) a_name (TEXT), default.a.r_name (TEXT)} SCAN(9) on eb_0000000000000_0000_000001 - => out schema: {(2) b_name (TEXT), default.b.r_name (TEXT)} - => in schema: {(2) b_name (TEXT), default.b.r_name (TEXT)} + => out schema: {(2) b_name (TEXT), default.b.n_name (TEXT)} + => in schema: {(2) b_name (TEXT), default.b.n_name (TEXT)} ======================================================= Block Id: eb_0000000000000_0000_000004 [TERMINAL] http://git-wip-us.apache.org/repos/asf/tajo/blob/f1cf1a24/tajo-core-tests/src/test/resources/results/TestCrossJoin/testCrossJoinWithThetaJoinConditionInWhere.Sort.plan ---------------------------------------------------------------------- diff --git a/tajo-core-tests/src/test/resources/results/TestCrossJoin/testCrossJoinWithThetaJoinConditionInWhere.Sort.plan b/tajo-core-tests/src/test/resources/results/TestCrossJoin/testCrossJoinWithThetaJoinConditionInWhere.Sort.plan index d161811..6ec39f9 100644 --- a/tajo-core-tests/src/test/resources/results/TestCrossJoin/testCrossJoinWithThetaJoinConditionInWhere.Sort.plan +++ b/tajo-core-tests/src/test/resources/results/TestCrossJoin/testCrossJoinWithThetaJoinConditionInWhere.Sort.plan @@ -3,21 +3,21 @@ explain PROJECTION(3) => Targets: a_name (TEXT), b_name (TEXT) => out schema: {(2) a_name (TEXT), b_name (TEXT)} - => in schema: {(4) a_name (TEXT), b_name (TEXT), default.a.r_name (TEXT), default.b.r_name (TEXT)} + => in schema: {(4) a_name (TEXT), b_name (TEXT), default.a.r_name (TEXT), default.b.n_name (TEXT)} SELECTION(6) - => Search Cond: default.a.r_name (TEXT) < default.b.r_name (TEXT) + => Search Cond: default.a.r_name (TEXT) < default.b.n_name (TEXT) JOIN(7)(CROSS) - => target list: a_name (TEXT), b_name (TEXT), default.a.r_name (TEXT), default.b.r_name (TEXT) - => out schema: {(4) a_name (TEXT), b_name (TEXT), default.a.r_name (TEXT), default.b.r_name (TEXT)} - => in schema: {(4) a_name (TEXT), b_name (TEXT), default.a.r_name (TEXT), default.b.r_name (TEXT)} + => target list: a_name (TEXT), b_name (TEXT), default.a.r_name (TEXT), default.b.n_name (TEXT) + => out schema: {(4) a_name (TEXT), b_name (TEXT), default.a.r_name (TEXT), default.b.n_name (TEXT)} + => in schema: {(4) a_name (TEXT), b_name (TEXT), default.a.r_name (TEXT), default.b.n_name (TEXT)} SCAN(0) on default.region as a => target list: default.a.r_name (TEXT) as a_name, default.a.r_name (TEXT) => out schema: {(2) a_name (TEXT), default.a.r_name (TEXT)} => in schema: {(3) default.a.r_comment (TEXT), default.a.r_name (TEXT), default.a.r_regionkey (INT4)} - SCAN(1) on default.region as b - => target list: default.b.r_name (TEXT) as b_name, default.b.r_name (TEXT) - => out schema: {(2) b_name (TEXT), default.b.r_name (TEXT)} - => in schema: {(3) default.b.r_comment (TEXT), default.b.r_name (TEXT), default.b.r_regionkey (INT4)} + SCAN(1) on default.nation as b + => target list: default.b.n_name (TEXT) as b_name, default.b.n_name (TEXT) + => out schema: {(2) b_name (TEXT), default.b.n_name (TEXT)} + => in schema: {(4) default.b.n_comment (TEXT), default.b.n_name (TEXT), default.b.n_nationkey (INT4), default.b.n_regionkey (INT4)} explain ------------------------------- ------------------------------------------------------------------------------- @@ -42,21 +42,21 @@ Block Id: eb_0000000000000_0000_000003 [ROOT] PROJECTION(3) => Targets: a_name (TEXT), b_name (TEXT) => out schema: {(2) a_name (TEXT), b_name (TEXT)} - => in schema: {(4) a_name (TEXT), b_name (TEXT), default.a.r_name (TEXT), default.b.r_name (TEXT)} + => in schema: {(4) a_name (TEXT), b_name (TEXT), default.a.r_name (TEXT), default.b.n_name (TEXT)} SELECTION(6) - => Search Cond: default.a.r_name (TEXT) < default.b.r_name (TEXT) + => Search Cond: default.a.r_name (TEXT) < default.b.n_name (TEXT) JOIN(7)(CROSS) - => target list: a_name (TEXT), b_name (TEXT), default.a.r_name (TEXT), default.b.r_name (TEXT) - => out schema: {(4) a_name (TEXT), b_name (TEXT), default.a.r_name (TEXT), default.b.r_name (TEXT)} - => in schema: {(4) a_name (TEXT), b_name (TEXT), default.a.r_name (TEXT), default.b.r_name (TEXT)} + => target list: a_name (TEXT), b_name (TEXT), default.a.r_name (TEXT), default.b.n_name (TEXT) + => out schema: {(4) a_name (TEXT), b_name (TEXT), default.a.r_name (TEXT), default.b.n_name (TEXT)} + => in schema: {(4) a_name (TEXT), b_name (TEXT), default.a.r_name (TEXT), default.b.n_name (TEXT)} SCAN(0) on default.region as a => target list: default.a.r_name (TEXT) as a_name, default.a.r_name (TEXT) => out schema: {(2) a_name (TEXT), default.a.r_name (TEXT)} => in schema: {(3) default.a.r_comment (TEXT), default.a.r_name (TEXT), default.a.r_regionkey (INT4)} - SCAN(1) on default.region as b - => target list: default.b.r_name (TEXT) as b_name, default.b.r_name (TEXT) - => out schema: {(2) b_name (TEXT), default.b.r_name (TEXT)} - => in schema: {(3) default.b.r_comment (TEXT), default.b.r_name (TEXT), default.b.r_regionkey (INT4)} + SCAN(1) on default.nation as b + => target list: default.b.n_name (TEXT) as b_name, default.b.n_name (TEXT) + => out schema: {(2) b_name (TEXT), default.b.n_name (TEXT)} + => in schema: {(4) default.b.n_comment (TEXT), default.b.n_name (TEXT), default.b.n_nationkey (INT4), default.b.n_regionkey (INT4)} ======================================================= Block Id: eb_0000000000000_0000_000004 [TERMINAL] http://git-wip-us.apache.org/repos/asf/tajo/blob/f1cf1a24/tajo-core-tests/src/test/resources/results/TestCrossJoin/testCrossJoinWithThetaJoinConditionInWhere.Sort_NoBroadcast.plan ---------------------------------------------------------------------- diff --git a/tajo-core-tests/src/test/resources/results/TestCrossJoin/testCrossJoinWithThetaJoinConditionInWhere.Sort_NoBroadcast.plan b/tajo-core-tests/src/test/resources/results/TestCrossJoin/testCrossJoinWithThetaJoinConditionInWhere.Sort_NoBroadcast.plan index cfbfa19..fd89830 100644 --- a/tajo-core-tests/src/test/resources/results/TestCrossJoin/testCrossJoinWithThetaJoinConditionInWhere.Sort_NoBroadcast.plan +++ b/tajo-core-tests/src/test/resources/results/TestCrossJoin/testCrossJoinWithThetaJoinConditionInWhere.Sort_NoBroadcast.plan @@ -3,21 +3,21 @@ explain PROJECTION(3) => Targets: a_name (TEXT), b_name (TEXT) => out schema: {(2) a_name (TEXT), b_name (TEXT)} - => in schema: {(4) a_name (TEXT), b_name (TEXT), default.a.r_name (TEXT), default.b.r_name (TEXT)} + => in schema: {(4) a_name (TEXT), b_name (TEXT), default.a.r_name (TEXT), default.b.n_name (TEXT)} SELECTION(6) - => Search Cond: default.a.r_name (TEXT) < default.b.r_name (TEXT) + => Search Cond: default.a.r_name (TEXT) < default.b.n_name (TEXT) JOIN(7)(CROSS) - => target list: a_name (TEXT), b_name (TEXT), default.a.r_name (TEXT), default.b.r_name (TEXT) - => out schema: {(4) a_name (TEXT), b_name (TEXT), default.a.r_name (TEXT), default.b.r_name (TEXT)} - => in schema: {(4) a_name (TEXT), b_name (TEXT), default.a.r_name (TEXT), default.b.r_name (TEXT)} + => target list: a_name (TEXT), b_name (TEXT), default.a.r_name (TEXT), default.b.n_name (TEXT) + => out schema: {(4) a_name (TEXT), b_name (TEXT), default.a.r_name (TEXT), default.b.n_name (TEXT)} + => in schema: {(4) a_name (TEXT), b_name (TEXT), default.a.r_name (TEXT), default.b.n_name (TEXT)} SCAN(0) on default.region as a => target list: default.a.r_name (TEXT) as a_name, default.a.r_name (TEXT) => out schema: {(2) a_name (TEXT), default.a.r_name (TEXT)} => in schema: {(3) default.a.r_comment (TEXT), default.a.r_name (TEXT), default.a.r_regionkey (INT4)} - SCAN(1) on default.region as b - => target list: default.b.r_name (TEXT) as b_name, default.b.r_name (TEXT) - => out schema: {(2) b_name (TEXT), default.b.r_name (TEXT)} - => in schema: {(3) default.b.r_comment (TEXT), default.b.r_name (TEXT), default.b.r_regionkey (INT4)} + SCAN(1) on default.nation as b + => target list: default.b.n_name (TEXT) as b_name, default.b.n_name (TEXT) + => out schema: {(2) b_name (TEXT), default.b.n_name (TEXT)} + => in schema: {(4) default.b.n_comment (TEXT), default.b.n_name (TEXT), default.b.n_nationkey (INT4), default.b.n_regionkey (INT4)} explain ------------------------------- ------------------------------------------------------------------------------- @@ -43,10 +43,10 @@ Block Id: eb_0000000000000_0000_000001 [LEAF] [Outgoing] [q_0000000000000_0000] 1 => 3 (type=HASH_SHUFFLE) -SCAN(1) on default.region as b - => target list: default.b.r_name (TEXT) as b_name, default.b.r_name (TEXT) - => out schema: {(2) b_name (TEXT), default.b.r_name (TEXT)} - => in schema: {(3) default.b.r_comment (TEXT), default.b.r_name (TEXT), default.b.r_regionkey (INT4)} +SCAN(1) on default.nation as b + => target list: default.b.n_name (TEXT) as b_name, default.b.n_name (TEXT) + => out schema: {(2) b_name (TEXT), default.b.n_name (TEXT)} + => in schema: {(4) default.b.n_comment (TEXT), default.b.n_name (TEXT), default.b.n_nationkey (INT4), default.b.n_regionkey (INT4)} ======================================================= Block Id: eb_0000000000000_0000_000002 [LEAF] @@ -71,19 +71,19 @@ Block Id: eb_0000000000000_0000_000003 [ROOT] PROJECTION(3) => Targets: a_name (TEXT), b_name (TEXT) => out schema: {(2) a_name (TEXT), b_name (TEXT)} - => in schema: {(4) a_name (TEXT), b_name (TEXT), default.a.r_name (TEXT), default.b.r_name (TEXT)} + => in schema: {(4) a_name (TEXT), b_name (TEXT), default.a.r_name (TEXT), default.b.n_name (TEXT)} SELECTION(6) - => Search Cond: default.a.r_name (TEXT) < default.b.r_name (TEXT) + => Search Cond: default.a.r_name (TEXT) < default.b.n_name (TEXT) JOIN(7)(CROSS) - => target list: a_name (TEXT), b_name (TEXT), default.a.r_name (TEXT), default.b.r_name (TEXT) - => out schema: {(4) a_name (TEXT), b_name (TEXT), default.a.r_name (TEXT), default.b.r_name (TEXT)} - => in schema: {(4) a_name (TEXT), b_name (TEXT), default.a.r_name (TEXT), default.b.r_name (TEXT)} + => target list: a_name (TEXT), b_name (TEXT), default.a.r_name (TEXT), default.b.n_name (TEXT) + => out schema: {(4) a_name (TEXT), b_name (TEXT), default.a.r_name (TEXT), default.b.n_name (TEXT)} + => in schema: {(4) a_name (TEXT), b_name (TEXT), default.a.r_name (TEXT), default.b.n_name (TEXT)} SCAN(10) on eb_0000000000000_0000_000002 => out schema: {(2) a_name (TEXT), default.a.r_name (TEXT)} => in schema: {(2) a_name (TEXT), default.a.r_name (TEXT)} SCAN(9) on eb_0000000000000_0000_000001 - => out schema: {(2) b_name (TEXT), default.b.r_name (TEXT)} - => in schema: {(2) b_name (TEXT), default.b.r_name (TEXT)} + => out schema: {(2) b_name (TEXT), default.b.n_name (TEXT)} + => in schema: {(2) b_name (TEXT), default.b.n_name (TEXT)} ======================================================= Block Id: eb_0000000000000_0000_000004 [TERMINAL] http://git-wip-us.apache.org/repos/asf/tajo/blob/f1cf1a24/tajo-core-tests/src/test/resources/results/TestCrossJoin/testCrossJoinWithThetaJoinConditionInWhere.result ---------------------------------------------------------------------- diff --git a/tajo-core-tests/src/test/resources/results/TestCrossJoin/testCrossJoinWithThetaJoinConditionInWhere.result b/tajo-core-tests/src/test/resources/results/TestCrossJoin/testCrossJoinWithThetaJoinConditionInWhere.result index 8ddc197..7437fb9 100644 --- a/tajo-core-tests/src/test/resources/results/TestCrossJoin/testCrossJoinWithThetaJoinConditionInWhere.result +++ b/tajo-core-tests/src/test/resources/results/TestCrossJoin/testCrossJoinWithThetaJoinConditionInWhere.result @@ -1,12 +1,101 @@ a_name,b_name ------------------------------- -AFRICA,AMERICA -AFRICA,ASIA -AFRICA,EUROPE -AFRICA,MIDDLE EAST -AMERICA,ASIA -AMERICA,EUROPE -AMERICA,MIDDLE EAST -ASIA,EUROPE -ASIA,MIDDLE EAST -EUROPE,MIDDLE EAST +AFRICA,ALGERIA +AFRICA,ARGENTINA +AFRICA,BRAZIL +AFRICA,CANADA +AFRICA,CHINA +AFRICA,EGYPT +AFRICA,ETHIOPIA +AFRICA,FRANCE +AFRICA,GERMANY +AFRICA,INDIA +AFRICA,INDONESIA +AFRICA,IRAN +AFRICA,IRAQ +AFRICA,JAPAN +AFRICA,JORDAN +AFRICA,KENYA +AFRICA,MOROCCO +AFRICA,MOZAMBIQUE +AFRICA,PERU +AFRICA,ROMANIA +AFRICA,RUSSIA +AFRICA,SAUDI ARABIA +AFRICA,UNITED KINGDOM +AFRICA,UNITED STATES +AFRICA,VIETNAM +AMERICA,ARGENTINA +AMERICA,BRAZIL +AMERICA,CANADA +AMERICA,CHINA +AMERICA,EGYPT +AMERICA,ETHIOPIA +AMERICA,FRANCE +AMERICA,GERMANY +AMERICA,INDIA +AMERICA,INDONESIA +AMERICA,IRAN +AMERICA,IRAQ +AMERICA,JAPAN +AMERICA,JORDAN +AMERICA,KENYA +AMERICA,MOROCCO +AMERICA,MOZAMBIQUE +AMERICA,PERU +AMERICA,ROMANIA +AMERICA,RUSSIA +AMERICA,SAUDI ARABIA +AMERICA,UNITED KINGDOM +AMERICA,UNITED STATES +AMERICA,VIETNAM +ASIA,BRAZIL +ASIA,CANADA +ASIA,CHINA +ASIA,EGYPT +ASIA,ETHIOPIA +ASIA,FRANCE +ASIA,GERMANY +ASIA,INDIA +ASIA,INDONESIA +ASIA,IRAN +ASIA,IRAQ +ASIA,JAPAN +ASIA,JORDAN +ASIA,KENYA +ASIA,MOROCCO +ASIA,MOZAMBIQUE +ASIA,PERU +ASIA,ROMANIA +ASIA,RUSSIA +ASIA,SAUDI ARABIA +ASIA,UNITED KINGDOM +ASIA,UNITED STATES +ASIA,VIETNAM +EUROPE,FRANCE +EUROPE,GERMANY +EUROPE,INDIA +EUROPE,INDONESIA +EUROPE,IRAN +EUROPE,IRAQ +EUROPE,JAPAN +EUROPE,JORDAN +EUROPE,KENYA +EUROPE,MOROCCO +EUROPE,MOZAMBIQUE +EUROPE,PERU +EUROPE,ROMANIA +EUROPE,RUSSIA +EUROPE,SAUDI ARABIA +EUROPE,UNITED KINGDOM +EUROPE,UNITED STATES +EUROPE,VIETNAM +MIDDLE EAST,MOROCCO +MIDDLE EAST,MOZAMBIQUE +MIDDLE EAST,PERU +MIDDLE EAST,ROMANIA +MIDDLE EAST,RUSSIA +MIDDLE EAST,SAUDI ARABIA +MIDDLE EAST,UNITED KINGDOM +MIDDLE EAST,UNITED STATES +MIDDLE EAST,VIETNAM http://git-wip-us.apache.org/repos/asf/tajo/blob/f1cf1a24/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testBroadcastTwoPartJoin.Hash.plan ---------------------------------------------------------------------- diff --git a/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testBroadcastTwoPartJoin.Hash.plan b/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testBroadcastTwoPartJoin.Hash.plan index bd3ba1a..96e8360 100644 --- a/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testBroadcastTwoPartJoin.Hash.plan +++ b/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testBroadcastTwoPartJoin.Hash.plan @@ -66,10 +66,10 @@ Block Id: eb_0000000000000_0000_000009 [LEAF] [q_0000000000000_0000] 9 => 10 (type=RANGE_SHUFFLE, key=default.lineitem.l_orderkey (INT4), default.nation.n_name (TEXT), default.part.p_name (TEXT), num=32) [Enforcers] - 0: type=Broadcast, tables=default.orders - 1: type=Broadcast, tables=default.part - 2: type=Broadcast, tables=default.lineitem - 3: type=Broadcast, tables=default.customer + 0: type=Broadcast, tables=default.customer + 1: type=Broadcast, tables=default.lineitem + 2: type=Broadcast, tables=default.orders + 3: type=Broadcast, tables=default.part SORT(26) => Sort Keys: default.lineitem.l_orderkey (INT4) (asc),default.part.p_name (TEXT) (asc),default.nation.n_name (TEXT) (asc) http://git-wip-us.apache.org/repos/asf/tajo/blob/f1cf1a24/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testBroadcastTwoPartJoin.Sort.plan ---------------------------------------------------------------------- diff --git a/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testBroadcastTwoPartJoin.Sort.plan b/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testBroadcastTwoPartJoin.Sort.plan index bd3ba1a..96e8360 100644 --- a/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testBroadcastTwoPartJoin.Sort.plan +++ b/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testBroadcastTwoPartJoin.Sort.plan @@ -66,10 +66,10 @@ Block Id: eb_0000000000000_0000_000009 [LEAF] [q_0000000000000_0000] 9 => 10 (type=RANGE_SHUFFLE, key=default.lineitem.l_orderkey (INT4), default.nation.n_name (TEXT), default.part.p_name (TEXT), num=32) [Enforcers] - 0: type=Broadcast, tables=default.orders - 1: type=Broadcast, tables=default.part - 2: type=Broadcast, tables=default.lineitem - 3: type=Broadcast, tables=default.customer + 0: type=Broadcast, tables=default.customer + 1: type=Broadcast, tables=default.lineitem + 2: type=Broadcast, tables=default.orders + 3: type=Broadcast, tables=default.part SORT(26) => Sort Keys: default.lineitem.l_orderkey (INT4) (asc),default.part.p_name (TEXT) (asc),default.nation.n_name (TEXT) (asc) http://git-wip-us.apache.org/repos/asf/tajo/blob/f1cf1a24/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testDifferentTypesJoinCondition.Hash.plan ---------------------------------------------------------------------- diff --git a/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testDifferentTypesJoinCondition.Hash.plan b/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testDifferentTypesJoinCondition.Hash.plan index 69ede30..fdf227c 100644 --- a/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testDifferentTypesJoinCondition.Hash.plan +++ b/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testDifferentTypesJoinCondition.Hash.plan @@ -32,7 +32,7 @@ Block Id: eb_0000000000000_0000_000003 [ROOT] ======================================================= [Enforcers] - 0: type=Broadcast, tables=default.t4 + 0: type=Broadcast, tables=default.t3 JOIN(5)(INNER) => Join Cond: default.t3.id (INT8) = ?int8_1 (INT8) http://git-wip-us.apache.org/repos/asf/tajo/blob/f1cf1a24/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testDifferentTypesJoinCondition.Sort.plan ---------------------------------------------------------------------- diff --git a/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testDifferentTypesJoinCondition.Sort.plan b/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testDifferentTypesJoinCondition.Sort.plan index 69ede30..fdf227c 100644 --- a/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testDifferentTypesJoinCondition.Sort.plan +++ b/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testDifferentTypesJoinCondition.Sort.plan @@ -32,7 +32,7 @@ Block Id: eb_0000000000000_0000_000003 [ROOT] ======================================================= [Enforcers] - 0: type=Broadcast, tables=default.t4 + 0: type=Broadcast, tables=default.t3 JOIN(5)(INNER) => Join Cond: default.t3.id (INT8) = ?int8_1 (INT8) http://git-wip-us.apache.org/repos/asf/tajo/blob/f1cf1a24/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testDifferentTypesJoinCondition.result ---------------------------------------------------------------------- diff --git a/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testDifferentTypesJoinCondition.result b/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testDifferentTypesJoinCondition.result index 3626882..9e0736c 100644 --- a/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testDifferentTypesJoinCondition.result +++ b/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testDifferentTypesJoinCondition.result @@ -1,7 +1,4 @@ id,name,score,type,id,name,score,type ------------------------------- -1,ooo,1.1,a,1,ooo,1.1,a -2,ppp,2.3,b,2,ppp,2.3,b -3,qqq,3.4,c,3,qqq,3.4,c -4,rrr,4.5,d,4,rrr,4.5,d -5,xxx,5.6,e,5,xxx,5.6,e +1,ooo,1.1,a,1,null,null,a +2,ppp,2.3,b,2,null,null,b http://git-wip-us.apache.org/repos/asf/tajo/blob/f1cf1a24/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testInnerJoinWithThetaJoinConditionInWhere.Hash.plan ---------------------------------------------------------------------- diff --git a/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testInnerJoinWithThetaJoinConditionInWhere.Hash.plan b/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testInnerJoinWithThetaJoinConditionInWhere.Hash.plan index b2f4ff1..7d8fe21 100644 --- a/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testInnerJoinWithThetaJoinConditionInWhere.Hash.plan +++ b/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testInnerJoinWithThetaJoinConditionInWhere.Hash.plan @@ -1,20 +1,20 @@ explain ------------------------------- SELECTION(6) - => Search Cond: default.a.r_name (TEXT) <= default.b.r_name (TEXT) + => Search Cond: default.a.r_name (TEXT) <= default.b.n_name (TEXT) JOIN(7)(INNER) - => Join Cond: default.a.r_regionkey (INT4) = default.b.r_regionkey (INT4) - => target list: default.a.r_name (TEXT), default.a.r_regionkey (INT4), default.b.r_name (TEXT) - => out schema: {(3) default.a.r_name (TEXT), default.a.r_regionkey (INT4), default.b.r_name (TEXT)} - => in schema: {(4) default.a.r_name (TEXT), default.a.r_regionkey (INT4), default.b.r_name (TEXT), default.b.r_regionkey (INT4)} + => Join Cond: default.a.r_regionkey (INT4) = default.b.n_regionkey (INT4) + => target list: default.a.r_name (TEXT), default.a.r_regionkey (INT4), default.b.n_name (TEXT) + => out schema: {(3) default.a.r_name (TEXT), default.a.r_regionkey (INT4), default.b.n_name (TEXT)} + => in schema: {(4) default.a.r_name (TEXT), default.a.r_regionkey (INT4), default.b.n_name (TEXT), default.b.n_regionkey (INT4)} SCAN(0) on default.region as a => target list: default.a.r_name (TEXT), default.a.r_regionkey (INT4) => out schema: {(2) default.a.r_name (TEXT), default.a.r_regionkey (INT4)} => in schema: {(3) default.a.r_comment (TEXT), default.a.r_name (TEXT), default.a.r_regionkey (INT4)} - SCAN(1) on default.region as b - => target list: default.b.r_name (TEXT), default.b.r_regionkey (INT4) - => out schema: {(2) default.b.r_name (TEXT), default.b.r_regionkey (INT4)} - => in schema: {(3) default.b.r_comment (TEXT), default.b.r_name (TEXT), default.b.r_regionkey (INT4)} + SCAN(1) on default.nation as b + => target list: default.b.n_name (TEXT), default.b.n_regionkey (INT4) + => out schema: {(2) default.b.n_name (TEXT), default.b.n_regionkey (INT4)} + => in schema: {(4) default.b.n_comment (TEXT), default.b.n_name (TEXT), default.b.n_nationkey (INT4), default.b.n_regionkey (INT4)} explain ------------------------------- ------------------------------------------------------------------------------- @@ -37,20 +37,20 @@ Block Id: eb_0000000000000_0000_000003 [ROOT] 0: type=Broadcast, tables=default.a SELECTION(6) - => Search Cond: default.a.r_name (TEXT) <= default.b.r_name (TEXT) + => Search Cond: default.a.r_name (TEXT) <= default.b.n_name (TEXT) JOIN(7)(INNER) - => Join Cond: default.a.r_regionkey (INT4) = default.b.r_regionkey (INT4) - => target list: default.a.r_name (TEXT), default.a.r_regionkey (INT4), default.b.r_name (TEXT) - => out schema: {(3) default.a.r_name (TEXT), default.a.r_regionkey (INT4), default.b.r_name (TEXT)} - => in schema: {(4) default.a.r_name (TEXT), default.a.r_regionkey (INT4), default.b.r_name (TEXT), default.b.r_regionkey (INT4)} + => Join Cond: default.a.r_regionkey (INT4) = default.b.n_regionkey (INT4) + => target list: default.a.r_name (TEXT), default.a.r_regionkey (INT4), default.b.n_name (TEXT) + => out schema: {(3) default.a.r_name (TEXT), default.a.r_regionkey (INT4), default.b.n_name (TEXT)} + => in schema: {(4) default.a.r_name (TEXT), default.a.r_regionkey (INT4), default.b.n_name (TEXT), default.b.n_regionkey (INT4)} SCAN(0) on default.region as a => target list: default.a.r_name (TEXT), default.a.r_regionkey (INT4) => out schema: {(2) default.a.r_name (TEXT), default.a.r_regionkey (INT4)} => in schema: {(3) default.a.r_comment (TEXT), default.a.r_name (TEXT), default.a.r_regionkey (INT4)} - SCAN(1) on default.region as b - => target list: default.b.r_name (TEXT), default.b.r_regionkey (INT4) - => out schema: {(2) default.b.r_name (TEXT), default.b.r_regionkey (INT4)} - => in schema: {(3) default.b.r_comment (TEXT), default.b.r_name (TEXT), default.b.r_regionkey (INT4)} + SCAN(1) on default.nation as b + => target list: default.b.n_name (TEXT), default.b.n_regionkey (INT4) + => out schema: {(2) default.b.n_name (TEXT), default.b.n_regionkey (INT4)} + => in schema: {(4) default.b.n_comment (TEXT), default.b.n_name (TEXT), default.b.n_nationkey (INT4), default.b.n_regionkey (INT4)} ======================================================= Block Id: eb_0000000000000_0000_000004 [TERMINAL] http://git-wip-us.apache.org/repos/asf/tajo/blob/f1cf1a24/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testInnerJoinWithThetaJoinConditionInWhere.Hash_NoBroadcast.plan ---------------------------------------------------------------------- diff --git a/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testInnerJoinWithThetaJoinConditionInWhere.Hash_NoBroadcast.plan b/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testInnerJoinWithThetaJoinConditionInWhere.Hash_NoBroadcast.plan index 79d5e7a..dbf04de 100644 --- a/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testInnerJoinWithThetaJoinConditionInWhere.Hash_NoBroadcast.plan +++ b/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testInnerJoinWithThetaJoinConditionInWhere.Hash_NoBroadcast.plan @@ -1,20 +1,20 @@ explain ------------------------------- SELECTION(6) - => Search Cond: default.a.r_name (TEXT) <= default.b.r_name (TEXT) + => Search Cond: default.a.r_name (TEXT) <= default.b.n_name (TEXT) JOIN(7)(INNER) - => Join Cond: default.a.r_regionkey (INT4) = default.b.r_regionkey (INT4) - => target list: default.a.r_name (TEXT), default.a.r_regionkey (INT4), default.b.r_name (TEXT) - => out schema: {(3) default.a.r_name (TEXT), default.a.r_regionkey (INT4), default.b.r_name (TEXT)} - => in schema: {(4) default.a.r_name (TEXT), default.a.r_regionkey (INT4), default.b.r_name (TEXT), default.b.r_regionkey (INT4)} + => Join Cond: default.a.r_regionkey (INT4) = default.b.n_regionkey (INT4) + => target list: default.a.r_name (TEXT), default.a.r_regionkey (INT4), default.b.n_name (TEXT) + => out schema: {(3) default.a.r_name (TEXT), default.a.r_regionkey (INT4), default.b.n_name (TEXT)} + => in schema: {(4) default.a.r_name (TEXT), default.a.r_regionkey (INT4), default.b.n_name (TEXT), default.b.n_regionkey (INT4)} SCAN(0) on default.region as a => target list: default.a.r_name (TEXT), default.a.r_regionkey (INT4) => out schema: {(2) default.a.r_name (TEXT), default.a.r_regionkey (INT4)} => in schema: {(3) default.a.r_comment (TEXT), default.a.r_name (TEXT), default.a.r_regionkey (INT4)} - SCAN(1) on default.region as b - => target list: default.b.r_name (TEXT), default.b.r_regionkey (INT4) - => out schema: {(2) default.b.r_name (TEXT), default.b.r_regionkey (INT4)} - => in schema: {(3) default.b.r_comment (TEXT), default.b.r_name (TEXT), default.b.r_regionkey (INT4)} + SCAN(1) on default.nation as b + => target list: default.b.n_name (TEXT), default.b.n_regionkey (INT4) + => out schema: {(2) default.b.n_name (TEXT), default.b.n_regionkey (INT4)} + => in schema: {(4) default.b.n_comment (TEXT), default.b.n_name (TEXT), default.b.n_nationkey (INT4), default.b.n_regionkey (INT4)} explain ------------------------------- ------------------------------------------------------------------------------- @@ -38,12 +38,12 @@ Block Id: eb_0000000000000_0000_000001 [LEAF] ======================================================= [Outgoing] -[q_0000000000000_0000] 1 => 3 (type=HASH_SHUFFLE, key=default.b.r_regionkey (INT4), num=32) +[q_0000000000000_0000] 1 => 3 (type=HASH_SHUFFLE, key=default.b.n_regionkey (INT4), num=32) -SCAN(1) on default.region as b - => target list: default.b.r_name (TEXT), default.b.r_regionkey (INT4) - => out schema: {(2) default.b.r_name (TEXT), default.b.r_regionkey (INT4)} - => in schema: {(3) default.b.r_comment (TEXT), default.b.r_name (TEXT), default.b.r_regionkey (INT4)} +SCAN(1) on default.nation as b + => target list: default.b.n_name (TEXT), default.b.n_regionkey (INT4) + => out schema: {(2) default.b.n_name (TEXT), default.b.n_regionkey (INT4)} + => in schema: {(4) default.b.n_comment (TEXT), default.b.n_name (TEXT), default.b.n_nationkey (INT4), default.b.n_regionkey (INT4)} ======================================================= Block Id: eb_0000000000000_0000_000002 [LEAF] @@ -62,22 +62,22 @@ Block Id: eb_0000000000000_0000_000003 [ROOT] ======================================================= [Incoming] -[q_0000000000000_0000] 1 => 3 (type=HASH_SHUFFLE, key=default.b.r_regionkey (INT4), num=32) +[q_0000000000000_0000] 1 => 3 (type=HASH_SHUFFLE, key=default.b.n_regionkey (INT4), num=32) [q_0000000000000_0000] 2 => 3 (type=HASH_SHUFFLE, key=default.a.r_regionkey (INT4), num=32) SELECTION(6) - => Search Cond: default.a.r_name (TEXT) <= default.b.r_name (TEXT) + => Search Cond: default.a.r_name (TEXT) <= default.b.n_name (TEXT) JOIN(7)(INNER) - => Join Cond: default.a.r_regionkey (INT4) = default.b.r_regionkey (INT4) - => target list: default.a.r_name (TEXT), default.a.r_regionkey (INT4), default.b.r_name (TEXT) - => out schema: {(3) default.a.r_name (TEXT), default.a.r_regionkey (INT4), default.b.r_name (TEXT)} - => in schema: {(4) default.a.r_name (TEXT), default.a.r_regionkey (INT4), default.b.r_name (TEXT), default.b.r_regionkey (INT4)} + => Join Cond: default.a.r_regionkey (INT4) = default.b.n_regionkey (INT4) + => target list: default.a.r_name (TEXT), default.a.r_regionkey (INT4), default.b.n_name (TEXT) + => out schema: {(3) default.a.r_name (TEXT), default.a.r_regionkey (INT4), default.b.n_name (TEXT)} + => in schema: {(4) default.a.r_name (TEXT), default.a.r_regionkey (INT4), default.b.n_name (TEXT), default.b.n_regionkey (INT4)} SCAN(10) on eb_0000000000000_0000_000002 => out schema: {(2) default.a.r_name (TEXT), default.a.r_regionkey (INT4)} => in schema: {(2) default.a.r_name (TEXT), default.a.r_regionkey (INT4)} SCAN(9) on eb_0000000000000_0000_000001 - => out schema: {(2) default.b.r_name (TEXT), default.b.r_regionkey (INT4)} - => in schema: {(2) default.b.r_name (TEXT), default.b.r_regionkey (INT4)} + => out schema: {(2) default.b.n_name (TEXT), default.b.n_regionkey (INT4)} + => in schema: {(2) default.b.n_name (TEXT), default.b.n_regionkey (INT4)} ======================================================= Block Id: eb_0000000000000_0000_000004 [TERMINAL] http://git-wip-us.apache.org/repos/asf/tajo/blob/f1cf1a24/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testInnerJoinWithThetaJoinConditionInWhere.Sort.plan ---------------------------------------------------------------------- diff --git a/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testInnerJoinWithThetaJoinConditionInWhere.Sort.plan b/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testInnerJoinWithThetaJoinConditionInWhere.Sort.plan index b2f4ff1..7d8fe21 100644 --- a/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testInnerJoinWithThetaJoinConditionInWhere.Sort.plan +++ b/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testInnerJoinWithThetaJoinConditionInWhere.Sort.plan @@ -1,20 +1,20 @@ explain ------------------------------- SELECTION(6) - => Search Cond: default.a.r_name (TEXT) <= default.b.r_name (TEXT) + => Search Cond: default.a.r_name (TEXT) <= default.b.n_name (TEXT) JOIN(7)(INNER) - => Join Cond: default.a.r_regionkey (INT4) = default.b.r_regionkey (INT4) - => target list: default.a.r_name (TEXT), default.a.r_regionkey (INT4), default.b.r_name (TEXT) - => out schema: {(3) default.a.r_name (TEXT), default.a.r_regionkey (INT4), default.b.r_name (TEXT)} - => in schema: {(4) default.a.r_name (TEXT), default.a.r_regionkey (INT4), default.b.r_name (TEXT), default.b.r_regionkey (INT4)} + => Join Cond: default.a.r_regionkey (INT4) = default.b.n_regionkey (INT4) + => target list: default.a.r_name (TEXT), default.a.r_regionkey (INT4), default.b.n_name (TEXT) + => out schema: {(3) default.a.r_name (TEXT), default.a.r_regionkey (INT4), default.b.n_name (TEXT)} + => in schema: {(4) default.a.r_name (TEXT), default.a.r_regionkey (INT4), default.b.n_name (TEXT), default.b.n_regionkey (INT4)} SCAN(0) on default.region as a => target list: default.a.r_name (TEXT), default.a.r_regionkey (INT4) => out schema: {(2) default.a.r_name (TEXT), default.a.r_regionkey (INT4)} => in schema: {(3) default.a.r_comment (TEXT), default.a.r_name (TEXT), default.a.r_regionkey (INT4)} - SCAN(1) on default.region as b - => target list: default.b.r_name (TEXT), default.b.r_regionkey (INT4) - => out schema: {(2) default.b.r_name (TEXT), default.b.r_regionkey (INT4)} - => in schema: {(3) default.b.r_comment (TEXT), default.b.r_name (TEXT), default.b.r_regionkey (INT4)} + SCAN(1) on default.nation as b + => target list: default.b.n_name (TEXT), default.b.n_regionkey (INT4) + => out schema: {(2) default.b.n_name (TEXT), default.b.n_regionkey (INT4)} + => in schema: {(4) default.b.n_comment (TEXT), default.b.n_name (TEXT), default.b.n_nationkey (INT4), default.b.n_regionkey (INT4)} explain ------------------------------- ------------------------------------------------------------------------------- @@ -37,20 +37,20 @@ Block Id: eb_0000000000000_0000_000003 [ROOT] 0: type=Broadcast, tables=default.a SELECTION(6) - => Search Cond: default.a.r_name (TEXT) <= default.b.r_name (TEXT) + => Search Cond: default.a.r_name (TEXT) <= default.b.n_name (TEXT) JOIN(7)(INNER) - => Join Cond: default.a.r_regionkey (INT4) = default.b.r_regionkey (INT4) - => target list: default.a.r_name (TEXT), default.a.r_regionkey (INT4), default.b.r_name (TEXT) - => out schema: {(3) default.a.r_name (TEXT), default.a.r_regionkey (INT4), default.b.r_name (TEXT)} - => in schema: {(4) default.a.r_name (TEXT), default.a.r_regionkey (INT4), default.b.r_name (TEXT), default.b.r_regionkey (INT4)} + => Join Cond: default.a.r_regionkey (INT4) = default.b.n_regionkey (INT4) + => target list: default.a.r_name (TEXT), default.a.r_regionkey (INT4), default.b.n_name (TEXT) + => out schema: {(3) default.a.r_name (TEXT), default.a.r_regionkey (INT4), default.b.n_name (TEXT)} + => in schema: {(4) default.a.r_name (TEXT), default.a.r_regionkey (INT4), default.b.n_name (TEXT), default.b.n_regionkey (INT4)} SCAN(0) on default.region as a => target list: default.a.r_name (TEXT), default.a.r_regionkey (INT4) => out schema: {(2) default.a.r_name (TEXT), default.a.r_regionkey (INT4)} => in schema: {(3) default.a.r_comment (TEXT), default.a.r_name (TEXT), default.a.r_regionkey (INT4)} - SCAN(1) on default.region as b - => target list: default.b.r_name (TEXT), default.b.r_regionkey (INT4) - => out schema: {(2) default.b.r_name (TEXT), default.b.r_regionkey (INT4)} - => in schema: {(3) default.b.r_comment (TEXT), default.b.r_name (TEXT), default.b.r_regionkey (INT4)} + SCAN(1) on default.nation as b + => target list: default.b.n_name (TEXT), default.b.n_regionkey (INT4) + => out schema: {(2) default.b.n_name (TEXT), default.b.n_regionkey (INT4)} + => in schema: {(4) default.b.n_comment (TEXT), default.b.n_name (TEXT), default.b.n_nationkey (INT4), default.b.n_regionkey (INT4)} ======================================================= Block Id: eb_0000000000000_0000_000004 [TERMINAL] http://git-wip-us.apache.org/repos/asf/tajo/blob/f1cf1a24/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testInnerJoinWithThetaJoinConditionInWhere.Sort_NoBroadcast.plan ---------------------------------------------------------------------- diff --git a/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testInnerJoinWithThetaJoinConditionInWhere.Sort_NoBroadcast.plan b/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testInnerJoinWithThetaJoinConditionInWhere.Sort_NoBroadcast.plan index 79d5e7a..dbf04de 100644 --- a/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testInnerJoinWithThetaJoinConditionInWhere.Sort_NoBroadcast.plan +++ b/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testInnerJoinWithThetaJoinConditionInWhere.Sort_NoBroadcast.plan @@ -1,20 +1,20 @@ explain ------------------------------- SELECTION(6) - => Search Cond: default.a.r_name (TEXT) <= default.b.r_name (TEXT) + => Search Cond: default.a.r_name (TEXT) <= default.b.n_name (TEXT) JOIN(7)(INNER) - => Join Cond: default.a.r_regionkey (INT4) = default.b.r_regionkey (INT4) - => target list: default.a.r_name (TEXT), default.a.r_regionkey (INT4), default.b.r_name (TEXT) - => out schema: {(3) default.a.r_name (TEXT), default.a.r_regionkey (INT4), default.b.r_name (TEXT)} - => in schema: {(4) default.a.r_name (TEXT), default.a.r_regionkey (INT4), default.b.r_name (TEXT), default.b.r_regionkey (INT4)} + => Join Cond: default.a.r_regionkey (INT4) = default.b.n_regionkey (INT4) + => target list: default.a.r_name (TEXT), default.a.r_regionkey (INT4), default.b.n_name (TEXT) + => out schema: {(3) default.a.r_name (TEXT), default.a.r_regionkey (INT4), default.b.n_name (TEXT)} + => in schema: {(4) default.a.r_name (TEXT), default.a.r_regionkey (INT4), default.b.n_name (TEXT), default.b.n_regionkey (INT4)} SCAN(0) on default.region as a => target list: default.a.r_name (TEXT), default.a.r_regionkey (INT4) => out schema: {(2) default.a.r_name (TEXT), default.a.r_regionkey (INT4)} => in schema: {(3) default.a.r_comment (TEXT), default.a.r_name (TEXT), default.a.r_regionkey (INT4)} - SCAN(1) on default.region as b - => target list: default.b.r_name (TEXT), default.b.r_regionkey (INT4) - => out schema: {(2) default.b.r_name (TEXT), default.b.r_regionkey (INT4)} - => in schema: {(3) default.b.r_comment (TEXT), default.b.r_name (TEXT), default.b.r_regionkey (INT4)} + SCAN(1) on default.nation as b + => target list: default.b.n_name (TEXT), default.b.n_regionkey (INT4) + => out schema: {(2) default.b.n_name (TEXT), default.b.n_regionkey (INT4)} + => in schema: {(4) default.b.n_comment (TEXT), default.b.n_name (TEXT), default.b.n_nationkey (INT4), default.b.n_regionkey (INT4)} explain ------------------------------- ------------------------------------------------------------------------------- @@ -38,12 +38,12 @@ Block Id: eb_0000000000000_0000_000001 [LEAF] ======================================================= [Outgoing] -[q_0000000000000_0000] 1 => 3 (type=HASH_SHUFFLE, key=default.b.r_regionkey (INT4), num=32) +[q_0000000000000_0000] 1 => 3 (type=HASH_SHUFFLE, key=default.b.n_regionkey (INT4), num=32) -SCAN(1) on default.region as b - => target list: default.b.r_name (TEXT), default.b.r_regionkey (INT4) - => out schema: {(2) default.b.r_name (TEXT), default.b.r_regionkey (INT4)} - => in schema: {(3) default.b.r_comment (TEXT), default.b.r_name (TEXT), default.b.r_regionkey (INT4)} +SCAN(1) on default.nation as b + => target list: default.b.n_name (TEXT), default.b.n_regionkey (INT4) + => out schema: {(2) default.b.n_name (TEXT), default.b.n_regionkey (INT4)} + => in schema: {(4) default.b.n_comment (TEXT), default.b.n_name (TEXT), default.b.n_nationkey (INT4), default.b.n_regionkey (INT4)} ======================================================= Block Id: eb_0000000000000_0000_000002 [LEAF] @@ -62,22 +62,22 @@ Block Id: eb_0000000000000_0000_000003 [ROOT] ======================================================= [Incoming] -[q_0000000000000_0000] 1 => 3 (type=HASH_SHUFFLE, key=default.b.r_regionkey (INT4), num=32) +[q_0000000000000_0000] 1 => 3 (type=HASH_SHUFFLE, key=default.b.n_regionkey (INT4), num=32) [q_0000000000000_0000] 2 => 3 (type=HASH_SHUFFLE, key=default.a.r_regionkey (INT4), num=32) SELECTION(6) - => Search Cond: default.a.r_name (TEXT) <= default.b.r_name (TEXT) + => Search Cond: default.a.r_name (TEXT) <= default.b.n_name (TEXT) JOIN(7)(INNER) - => Join Cond: default.a.r_regionkey (INT4) = default.b.r_regionkey (INT4) - => target list: default.a.r_name (TEXT), default.a.r_regionkey (INT4), default.b.r_name (TEXT) - => out schema: {(3) default.a.r_name (TEXT), default.a.r_regionkey (INT4), default.b.r_name (TEXT)} - => in schema: {(4) default.a.r_name (TEXT), default.a.r_regionkey (INT4), default.b.r_name (TEXT), default.b.r_regionkey (INT4)} + => Join Cond: default.a.r_regionkey (INT4) = default.b.n_regionkey (INT4) + => target list: default.a.r_name (TEXT), default.a.r_regionkey (INT4), default.b.n_name (TEXT) + => out schema: {(3) default.a.r_name (TEXT), default.a.r_regionkey (INT4), default.b.n_name (TEXT)} + => in schema: {(4) default.a.r_name (TEXT), default.a.r_regionkey (INT4), default.b.n_name (TEXT), default.b.n_regionkey (INT4)} SCAN(10) on eb_0000000000000_0000_000002 => out schema: {(2) default.a.r_name (TEXT), default.a.r_regionkey (INT4)} => in schema: {(2) default.a.r_name (TEXT), default.a.r_regionkey (INT4)} SCAN(9) on eb_0000000000000_0000_000001 - => out schema: {(2) default.b.r_name (TEXT), default.b.r_regionkey (INT4)} - => in schema: {(2) default.b.r_name (TEXT), default.b.r_regionkey (INT4)} + => out schema: {(2) default.b.n_name (TEXT), default.b.n_regionkey (INT4)} + => in schema: {(2) default.b.n_name (TEXT), default.b.n_regionkey (INT4)} ======================================================= Block Id: eb_0000000000000_0000_000004 [TERMINAL] http://git-wip-us.apache.org/repos/asf/tajo/blob/f1cf1a24/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testInnerJoinWithThetaJoinConditionInWhere.result ---------------------------------------------------------------------- diff --git a/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testInnerJoinWithThetaJoinConditionInWhere.result b/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testInnerJoinWithThetaJoinConditionInWhere.result index 850ee29..dd0da93 100644 --- a/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testInnerJoinWithThetaJoinConditionInWhere.result +++ b/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testInnerJoinWithThetaJoinConditionInWhere.result @@ -1,7 +1,23 @@ -r_regionkey,r_name,r_name +r_regionkey,r_name,n_name ------------------------------- -0,AFRICA,AFRICA -1,AMERICA,AMERICA -2,ASIA,ASIA -3,EUROPE,EUROPE -4,MIDDLE EAST,MIDDLE EAST +0,AFRICA,ALGERIA +0,AFRICA,ETHIOPIA +0,AFRICA,KENYA +0,AFRICA,MOROCCO +0,AFRICA,MOZAMBIQUE +1,AMERICA,ARGENTINA +1,AMERICA,BRAZIL +1,AMERICA,CANADA +1,AMERICA,PERU +1,AMERICA,UNITED STATES +2,ASIA,CHINA +2,ASIA,INDIA +2,ASIA,INDONESIA +2,ASIA,JAPAN +2,ASIA,VIETNAM +3,EUROPE,FRANCE +3,EUROPE,GERMANY +3,EUROPE,ROMANIA +3,EUROPE,RUSSIA +3,EUROPE,UNITED KINGDOM +4,MIDDLE EAST,SAUDI ARABIA http://git-wip-us.apache.org/repos/asf/tajo/blob/f1cf1a24/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testJoinOnMultipleDatabases.Hash.plan ---------------------------------------------------------------------- diff --git a/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testJoinOnMultipleDatabases.Hash.plan b/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testJoinOnMultipleDatabases.Hash.plan index c982ee3..4bb88a4 100644 --- a/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testJoinOnMultipleDatabases.Hash.plan +++ b/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testJoinOnMultipleDatabases.Hash.plan @@ -66,10 +66,10 @@ Block Id: eb_0000000000000_0000_000009 [LEAF] [q_0000000000000_0000] 9 => 10 (type=RANGE_SHUFFLE, key=default.nation.n_name (TEXT), joins.part_.p_partkey (INT4), joins.supplier_.s_acctbal (FLOAT8), joins.supplier_.s_name (TEXT), num=32) [Enforcers] - 0: type=Broadcast, tables=joins.supplier_ - 1: type=Broadcast, tables=joins.part_ - 2: type=Broadcast, tables=default.partsupp - 3: type=Broadcast, tables=default.region + 0: type=Broadcast, tables=default.partsupp + 1: type=Broadcast, tables=default.region + 2: type=Broadcast, tables=joins.part_ + 3: type=Broadcast, tables=joins.supplier_ SORT(26) => Sort Keys: joins.supplier_.s_acctbal (FLOAT8) (asc),joins.supplier_.s_name (TEXT) (asc),default.nation.n_name (TEXT) (asc),joins.part_.p_partkey (INT4) (asc) http://git-wip-us.apache.org/repos/asf/tajo/blob/f1cf1a24/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testJoinOnMultipleDatabases.Sort.plan ---------------------------------------------------------------------- diff --git a/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testJoinOnMultipleDatabases.Sort.plan b/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testJoinOnMultipleDatabases.Sort.plan index c982ee3..4bb88a4 100644 --- a/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testJoinOnMultipleDatabases.Sort.plan +++ b/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testJoinOnMultipleDatabases.Sort.plan @@ -66,10 +66,10 @@ Block Id: eb_0000000000000_0000_000009 [LEAF] [q_0000000000000_0000] 9 => 10 (type=RANGE_SHUFFLE, key=default.nation.n_name (TEXT), joins.part_.p_partkey (INT4), joins.supplier_.s_acctbal (FLOAT8), joins.supplier_.s_name (TEXT), num=32) [Enforcers] - 0: type=Broadcast, tables=joins.supplier_ - 1: type=Broadcast, tables=joins.part_ - 2: type=Broadcast, tables=default.partsupp - 3: type=Broadcast, tables=default.region + 0: type=Broadcast, tables=default.partsupp + 1: type=Broadcast, tables=default.region + 2: type=Broadcast, tables=joins.part_ + 3: type=Broadcast, tables=joins.supplier_ SORT(26) => Sort Keys: joins.supplier_.s_acctbal (FLOAT8) (asc),joins.supplier_.s_name (TEXT) (asc),default.nation.n_name (TEXT) (asc),joins.part_.p_partkey (INT4) (asc) http://git-wip-us.apache.org/repos/asf/tajo/blob/f1cf1a24/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testJoinWithMultipleJoinQual1.Hash.plan ---------------------------------------------------------------------- diff --git a/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testJoinWithMultipleJoinQual1.Hash.plan b/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testJoinWithMultipleJoinQual1.Hash.plan index 8570bc7..ccbd219 100644 --- a/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testJoinWithMultipleJoinQual1.Hash.plan +++ b/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testJoinWithMultipleJoinQual1.Hash.plan @@ -66,10 +66,10 @@ Block Id: eb_0000000000000_0000_000009 [LEAF] [q_0000000000000_0000] 9 => 10 (type=RANGE_SHUFFLE, key=default.n.n_name (TEXT), default.p.p_partkey (INT4), default.s.s_acctbal (FLOAT8), default.s.s_name (TEXT), num=32) [Enforcers] - 0: type=Broadcast, tables=default.ps - 1: type=Broadcast, tables=default.p - 2: type=Broadcast, tables=default.s - 3: type=Broadcast, tables=default.r + 0: type=Broadcast, tables=default.p + 1: type=Broadcast, tables=default.ps + 2: type=Broadcast, tables=default.r + 3: type=Broadcast, tables=default.s SORT(26) => Sort Keys: default.s.s_acctbal (FLOAT8) (asc),default.s.s_name (TEXT) (asc),default.n.n_name (TEXT) (asc),default.p.p_partkey (INT4) (asc) http://git-wip-us.apache.org/repos/asf/tajo/blob/f1cf1a24/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testJoinWithMultipleJoinQual1.Sort.plan ---------------------------------------------------------------------- diff --git a/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testJoinWithMultipleJoinQual1.Sort.plan b/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testJoinWithMultipleJoinQual1.Sort.plan index 8570bc7..ccbd219 100644 --- a/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testJoinWithMultipleJoinQual1.Sort.plan +++ b/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testJoinWithMultipleJoinQual1.Sort.plan @@ -66,10 +66,10 @@ Block Id: eb_0000000000000_0000_000009 [LEAF] [q_0000000000000_0000] 9 => 10 (type=RANGE_SHUFFLE, key=default.n.n_name (TEXT), default.p.p_partkey (INT4), default.s.s_acctbal (FLOAT8), default.s.s_name (TEXT), num=32) [Enforcers] - 0: type=Broadcast, tables=default.ps - 1: type=Broadcast, tables=default.p - 2: type=Broadcast, tables=default.s - 3: type=Broadcast, tables=default.r + 0: type=Broadcast, tables=default.p + 1: type=Broadcast, tables=default.ps + 2: type=Broadcast, tables=default.r + 3: type=Broadcast, tables=default.s SORT(26) => Sort Keys: default.s.s_acctbal (FLOAT8) (asc),default.s.s_name (TEXT) (asc),default.n.n_name (TEXT) (asc),default.p.p_partkey (INT4) (asc) http://git-wip-us.apache.org/repos/asf/tajo/blob/f1cf1a24/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testTPCHQ2Join.Hash.plan ---------------------------------------------------------------------- diff --git a/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testTPCHQ2Join.Hash.plan b/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testTPCHQ2Join.Hash.plan index baad6d4..ba4afc1 100644 --- a/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testTPCHQ2Join.Hash.plan +++ b/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testTPCHQ2Join.Hash.plan @@ -67,9 +67,9 @@ Block Id: eb_0000000000000_0000_000009 [LEAF] [Enforcers] 0: type=Broadcast, tables=default.part - 1: type=Broadcast, tables=default.supplier - 2: type=Broadcast, tables=default.partsupp - 3: type=Broadcast, tables=default.region + 1: type=Broadcast, tables=default.partsupp + 2: type=Broadcast, tables=default.region + 3: type=Broadcast, tables=default.supplier SORT(26) => Sort Keys: default.supplier.s_acctbal (FLOAT8) (asc),default.supplier.s_name (TEXT) (asc),default.nation.n_name (TEXT) (asc),default.part.p_partkey (INT4) (asc) http://git-wip-us.apache.org/repos/asf/tajo/blob/f1cf1a24/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testTPCHQ2Join.Sort.plan ---------------------------------------------------------------------- diff --git a/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testTPCHQ2Join.Sort.plan b/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testTPCHQ2Join.Sort.plan index baad6d4..ba4afc1 100644 --- a/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testTPCHQ2Join.Sort.plan +++ b/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testTPCHQ2Join.Sort.plan @@ -67,9 +67,9 @@ Block Id: eb_0000000000000_0000_000009 [LEAF] [Enforcers] 0: type=Broadcast, tables=default.part - 1: type=Broadcast, tables=default.supplier - 2: type=Broadcast, tables=default.partsupp - 3: type=Broadcast, tables=default.region + 1: type=Broadcast, tables=default.partsupp + 2: type=Broadcast, tables=default.region + 3: type=Broadcast, tables=default.supplier SORT(26) => Sort Keys: default.supplier.s_acctbal (FLOAT8) (asc),default.supplier.s_name (TEXT) (asc),default.nation.n_name (TEXT) (asc),default.part.p_partkey (INT4) (asc) http://git-wip-us.apache.org/repos/asf/tajo/blob/f1cf1a24/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testWhereClauseJoin5.Hash.plan ---------------------------------------------------------------------- diff --git a/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testWhereClauseJoin5.Hash.plan b/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testWhereClauseJoin5.Hash.plan index cfde80a..ee08a7b 100644 --- a/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testWhereClauseJoin5.Hash.plan +++ b/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testWhereClauseJoin5.Hash.plan @@ -48,8 +48,8 @@ Block Id: eb_0000000000000_0000_000005 [LEAF] [q_0000000000000_0000] 5 => 6 (type=RANGE_SHUFFLE, key=default.part.p_partkey (INT4), default.supplier.s_acctbal (FLOAT8), default.supplier.s_name (TEXT), num=32) [Enforcers] - 0: type=Broadcast, tables=default.supplier - 1: type=Broadcast, tables=default.partsupp + 0: type=Broadcast, tables=default.partsupp + 1: type=Broadcast, tables=default.supplier SORT(16) => Sort Keys: default.supplier.s_acctbal (FLOAT8) (asc),default.supplier.s_name (TEXT) (asc),default.part.p_partkey (INT4) (asc) http://git-wip-us.apache.org/repos/asf/tajo/blob/f1cf1a24/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testWhereClauseJoin5.Sort.plan ---------------------------------------------------------------------- diff --git a/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testWhereClauseJoin5.Sort.plan b/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testWhereClauseJoin5.Sort.plan index cfde80a..ee08a7b 100644 --- a/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testWhereClauseJoin5.Sort.plan +++ b/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testWhereClauseJoin5.Sort.plan @@ -48,8 +48,8 @@ Block Id: eb_0000000000000_0000_000005 [LEAF] [q_0000000000000_0000] 5 => 6 (type=RANGE_SHUFFLE, key=default.part.p_partkey (INT4), default.supplier.s_acctbal (FLOAT8), default.supplier.s_name (TEXT), num=32) [Enforcers] - 0: type=Broadcast, tables=default.supplier - 1: type=Broadcast, tables=default.partsupp + 0: type=Broadcast, tables=default.partsupp + 1: type=Broadcast, tables=default.supplier SORT(16) => Sort Keys: default.supplier.s_acctbal (FLOAT8) (asc),default.supplier.s_name (TEXT) (asc),default.part.p_partkey (INT4) (asc) http://git-wip-us.apache.org/repos/asf/tajo/blob/f1cf1a24/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testWhereClauseJoin6.Hash.plan ---------------------------------------------------------------------- diff --git a/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testWhereClauseJoin6.Hash.plan b/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testWhereClauseJoin6.Hash.plan index 038f468..b3f04c8 100644 --- a/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testWhereClauseJoin6.Hash.plan +++ b/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testWhereClauseJoin6.Hash.plan @@ -58,8 +58,8 @@ Block Id: eb_0000000000000_0000_000007 [LEAF] [Enforcers] 0: type=Broadcast, tables=default.part - 1: type=Broadcast, tables=default.supplier - 2: type=Broadcast, tables=default.partsupp + 1: type=Broadcast, tables=default.partsupp + 2: type=Broadcast, tables=default.supplier SORT(21) => Sort Keys: default.supplier.s_acctbal (FLOAT8) (asc),default.supplier.s_name (TEXT) (asc),default.part.p_partkey (INT4) (asc),default.nation.n_name (TEXT) (asc) http://git-wip-us.apache.org/repos/asf/tajo/blob/f1cf1a24/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testWhereClauseJoin6.Sort.plan ---------------------------------------------------------------------- diff --git a/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testWhereClauseJoin6.Sort.plan b/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testWhereClauseJoin6.Sort.plan index 038f468..b3f04c8 100644 --- a/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testWhereClauseJoin6.Sort.plan +++ b/tajo-core-tests/src/test/resources/results/TestInnerJoinQuery/testWhereClauseJoin6.Sort.plan @@ -58,8 +58,8 @@ Block Id: eb_0000000000000_0000_000007 [LEAF] [Enforcers] 0: type=Broadcast, tables=default.part - 1: type=Broadcast, tables=default.supplier - 2: type=Broadcast, tables=default.partsupp + 1: type=Broadcast, tables=default.partsupp + 2: type=Broadcast, tables=default.supplier SORT(21) => Sort Keys: default.supplier.s_acctbal (FLOAT8) (asc),default.supplier.s_name (TEXT) (asc),default.part.p_partkey (INT4) (asc),default.nation.n_name (TEXT) (asc) http://git-wip-us.apache.org/repos/asf/tajo/blob/f1cf1a24/tajo-core-tests/src/test/resources/results/TestInnerJoinWithSubQuery/testBroadcastSubquery.Hash.plan ---------------------------------------------------------------------- diff --git a/tajo-core-tests/src/test/resources/results/TestInnerJoinWithSubQuery/testBroadcastSubquery.Hash.plan b/tajo-core-tests/src/test/resources/results/TestInnerJoinWithSubQuery/testBroadcastSubquery.Hash.plan index 9685885..714ab21 100644 --- a/tajo-core-tests/src/test/resources/results/TestInnerJoinWithSubQuery/testBroadcastSubquery.Hash.plan +++ b/tajo-core-tests/src/test/resources/results/TestInnerJoinWithSubQuery/testBroadcastSubquery.Hash.plan @@ -52,8 +52,8 @@ Block Id: eb_0000000000000_0000_000005 [LEAF] [q_0000000000000_0000] 5 => 6 (type=RANGE_SHUFFLE, key=default.a.o_custkey (INT4), default.lineitem.l_orderkey (INT4), default.part.p_name (TEXT), num=32) [Enforcers] - 0: type=Broadcast, tables=default.part - 1: type=Broadcast, tables=default.orders + 0: type=Broadcast, tables=default.orders + 1: type=Broadcast, tables=default.part SORT(18) => Sort Keys: default.lineitem.l_orderkey (INT4) (asc),default.a.o_custkey (INT4) (asc),default.part.p_name (TEXT) (asc) http://git-wip-us.apache.org/repos/asf/tajo/blob/f1cf1a24/tajo-core-tests/src/test/resources/results/TestInnerJoinWithSubQuery/testBroadcastSubquery.Sort.plan ---------------------------------------------------------------------- diff --git a/tajo-core-tests/src/test/resources/results/TestInnerJoinWithSubQuery/testBroadcastSubquery.Sort.plan b/tajo-core-tests/src/test/resources/results/TestInnerJoinWithSubQuery/testBroadcastSubquery.Sort.plan index 9685885..714ab21 100644 --- a/tajo-core-tests/src/test/resources/results/TestInnerJoinWithSubQuery/testBroadcastSubquery.Sort.plan +++ b/tajo-core-tests/src/test/resources/results/TestInnerJoinWithSubQuery/testBroadcastSubquery.Sort.plan @@ -52,8 +52,8 @@ Block Id: eb_0000000000000_0000_000005 [LEAF] [q_0000000000000_0000] 5 => 6 (type=RANGE_SHUFFLE, key=default.a.o_custkey (INT4), default.lineitem.l_orderkey (INT4), default.part.p_name (TEXT), num=32) [Enforcers] - 0: type=Broadcast, tables=default.part - 1: type=Broadcast, tables=default.orders + 0: type=Broadcast, tables=default.orders + 1: type=Broadcast, tables=default.part SORT(18) => Sort Keys: default.lineitem.l_orderkey (INT4) (asc),default.a.o_custkey (INT4) (asc),default.part.p_name (TEXT) (asc) http://git-wip-us.apache.org/repos/asf/tajo/blob/f1cf1a24/tajo-core-tests/src/test/resources/results/TestInnerJoinWithSubQuery/testBroadcastSubquery2.Hash.plan ---------------------------------------------------------------------- diff --git a/tajo-core-tests/src/test/resources/results/TestInnerJoinWithSubQuery/testBroadcastSubquery2.Hash.plan b/tajo-core-tests/src/test/resources/results/TestInnerJoinWithSubQuery/testBroadcastSubquery2.Hash.plan index 5def40e..20fe5ee 100644 --- a/tajo-core-tests/src/test/resources/results/TestInnerJoinWithSubQuery/testBroadcastSubquery2.Hash.plan +++ b/tajo-core-tests/src/test/resources/results/TestInnerJoinWithSubQuery/testBroadcastSubquery2.Hash.plan @@ -131,9 +131,9 @@ Block Id: eb_0000000000000_0000_000010 [INTERMEDIATE] [q_0000000000000_0000] 10 => 11 (type=HASH_SHUFFLE, key=, num=1) [Enforcers] - 0: type=Broadcast, tables=default.part - 1: type=Broadcast, tables=default.a - 2: type=Broadcast, tables=default.c + 0: type=Broadcast, tables=default.a + 1: type=Broadcast, tables=default.c + 2: type=Broadcast, tables=default.part GROUP_BY(36)() => exprs: (sum(default.b.l_quantity (FLOAT8))) http://git-wip-us.apache.org/repos/asf/tajo/blob/f1cf1a24/tajo-core-tests/src/test/resources/results/TestInnerJoinWithSubQuery/testBroadcastSubquery2.Sort.plan ---------------------------------------------------------------------- diff --git a/tajo-core-tests/src/test/resources/results/TestInnerJoinWithSubQuery/testBroadcastSubquery2.Sort.plan b/tajo-core-tests/src/test/resources/results/TestInnerJoinWithSubQuery/testBroadcastSubquery2.Sort.plan index 5def40e..20fe5ee 100644 --- a/tajo-core-tests/src/test/resources/results/TestInnerJoinWithSubQuery/testBroadcastSubquery2.Sort.plan +++ b/tajo-core-tests/src/test/resources/results/TestInnerJoinWithSubQuery/testBroadcastSubquery2.Sort.plan @@ -131,9 +131,9 @@ Block Id: eb_0000000000000_0000_000010 [INTERMEDIATE] [q_0000000000000_0000] 10 => 11 (type=HASH_SHUFFLE, key=, num=1) [Enforcers] - 0: type=Broadcast, tables=default.part - 1: type=Broadcast, tables=default.a - 2: type=Broadcast, tables=default.c + 0: type=Broadcast, tables=default.a + 1: type=Broadcast, tables=default.c + 2: type=Broadcast, tables=default.part GROUP_BY(36)() => exprs: (sum(default.b.l_quantity (FLOAT8)))
