tajo-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jihoon...@apache.org
Subject [1/2] tajo git commit: TAJO-1630: Test failure after TAJO-1130. (jihoon)
Date Thu, 28 May 2015 09:40:43 GMT
Repository: tajo
Updated Branches:
  refs/heads/master c2725a779 -> f4680a933


http://git-wip-us.apache.org/repos/asf/tajo/blob/f4680a93/tajo-core/src/test/resources/results/TestOuterJoinQuery/testLeftOuterJoinWithEmptyTable4.Sort_NoBroadcast.plan
----------------------------------------------------------------------
diff --git a/tajo-core/src/test/resources/results/TestOuterJoinQuery/testLeftOuterJoinWithEmptyTable4.Sort_NoBroadcast.plan
b/tajo-core/src/test/resources/results/TestOuterJoinQuery/testLeftOuterJoinWithEmptyTable4.Sort_NoBroadcast.plan
index 73478b2..21bb1de 100644
--- a/tajo-core/src/test/resources/results/TestOuterJoinQuery/testLeftOuterJoinWithEmptyTable4.Sort_NoBroadcast.plan
+++ b/tajo-core/src/test/resources/results/TestOuterJoinQuery/testLeftOuterJoinWithEmptyTable4.Sort_NoBroadcast.plan
@@ -126,22 +126,6 @@ GROUP_BY(17)()
         => in schema: {(1) default.customer.c_custkey (INT4)}
 
 =======================================================
-Block Id: eb_0000000000000_0000_000004 [ROOT]
-=======================================================
-
-[Incoming]
-[q_0000000000000_0000] 3 => 4 (type=HASH_SHUFFLE, key=, num=1)
-
-GROUP_BY(9)()
-  => exprs: (max(?max_12 (INT4)),sum(?sum_13 (INT8)),max(?max_14 (TEXT)),max(?max_15 (TEXT)))
-  => target list: ?max (INT4), ?sum_1 (INT8), ?max_2 (TEXT), ?max_3 (TEXT)
-  => out schema:{(4) ?max (INT4), ?max_2 (TEXT), ?max_3 (TEXT), ?sum_1 (INT8)}
-  => in schema:{(4) ?max_12 (INT4), ?sum_13 (INT8), ?max_14 (TEXT), ?max_15 (TEXT)}
-   SCAN(18) on eb_0000000000000_0000_000003
-     => out schema: {(4) ?max_12 (INT4), ?sum_13 (INT8), ?max_14 (TEXT), ?max_15 (TEXT)}
-     => in schema: {(4) ?max_12 (INT4), ?sum_13 (INT8), ?max_14 (TEXT), ?max_15 (TEXT)}
-
-=======================================================
 Block Id: eb_0000000000000_0000_000005 [LEAF]
 =======================================================
 
@@ -166,6 +150,22 @@ SCAN(5) on default.empty_orders
   => in schema: {(9) default.empty_orders.o_clerk (TEXT), default.empty_orders.o_comment
(TEXT), default.empty_orders.o_custkey (INT4), default.empty_orders.o_orderdate (TEXT), default.empty_orders.o_orderkey
(INT4), default.empty_orders.o_orderpriority (TEXT), default.empty_orders.o_orderstatus (TEXT),
default.empty_orders.o_shippriority (INT4), default.empty_orders.o_totalprice (FLOAT8)}
 
 =======================================================
+Block Id: eb_0000000000000_0000_000004 [ROOT]
+=======================================================
+
+[Incoming]
+[q_0000000000000_0000] 3 => 4 (type=HASH_SHUFFLE, key=, num=1)
+
+GROUP_BY(9)()
+  => exprs: (max(?max_12 (INT4)),sum(?sum_13 (INT8)),max(?max_14 (TEXT)),max(?max_15 (TEXT)))
+  => target list: ?max (INT4), ?sum_1 (INT8), ?max_2 (TEXT), ?max_3 (TEXT)
+  => out schema:{(4) ?max (INT4), ?max_2 (TEXT), ?max_3 (TEXT), ?sum_1 (INT8)}
+  => in schema:{(4) ?max_12 (INT4), ?sum_13 (INT8), ?max_14 (TEXT), ?max_15 (TEXT)}
+   SCAN(18) on eb_0000000000000_0000_000003
+     => out schema: {(4) ?max_12 (INT4), ?sum_13 (INT8), ?max_14 (TEXT), ?max_15 (TEXT)}
+     => in schema: {(4) ?max_12 (INT4), ?sum_13 (INT8), ?max_14 (TEXT), ?max_15 (TEXT)}
+
+=======================================================
 Block Id: eb_0000000000000_0000_000007 [INTERMEDIATE]
 =======================================================
 

http://git-wip-us.apache.org/repos/asf/tajo/blob/f4680a93/tajo-core/src/test/resources/results/TestOuterJoinWithSubQuery/testJoinWithDifferentShuffleKey.1.Hash.plan
----------------------------------------------------------------------
diff --git a/tajo-core/src/test/resources/results/TestOuterJoinWithSubQuery/testJoinWithDifferentShuffleKey.1.Hash.plan
b/tajo-core/src/test/resources/results/TestOuterJoinWithSubQuery/testJoinWithDifferentShuffleKey.1.Hash.plan
index b9b9adf..f33e844 100644
--- a/tajo-core/src/test/resources/results/TestOuterJoinWithSubQuery/testJoinWithDifferentShuffleKey.1.Hash.plan
+++ b/tajo-core/src/test/resources/results/TestOuterJoinWithSubQuery/testJoinWithDifferentShuffleKey.1.Hash.plan
@@ -79,6 +79,24 @@ GROUP_BY(15)(id)
      => in schema: {(2) default.jointable_large.id (INT4), default.jointable_large.name
(TEXT)}
 
 =======================================================
+Block Id: eb_0000000000000_0000_000003 [LEAF]
+=======================================================
+
+[Outgoing]
+[q_0000000000000_0000] 3 => 4 (type=HASH_SHUFFLE, key=default.jointable_large.id (INT4),
num=32)
+
+GROUP_BY(17)(id)
+  => exprs: (count())
+  => target list: default.jointable_large.id (INT4), ?count_5 (INT8)
+  => out schema:{(2) default.jointable_large.id (INT4), ?count_5 (INT8)}
+  => in schema:{(1) default.jointable_large.id (INT4)}
+   SCAN(4) on default.jointable_large
+     => filter: default.jointable_large.id (INT4) < 200
+     => target list: default.jointable_large.id (INT4)
+     => out schema: {(1) default.jointable_large.id (INT4)}
+     => in schema: {(2) default.jointable_large.id (INT4), default.jointable_large.name
(TEXT)}
+
+=======================================================
 Block Id: eb_0000000000000_0000_000002 [INTERMEDIATE]
 =======================================================
 
@@ -106,24 +124,6 @@ TABLE_SUBQUERY(3) as default.a
            => in schema: {(2) default.jointable_large.id (INT4), ?count_4 (INT8)}
 
 =======================================================
-Block Id: eb_0000000000000_0000_000003 [LEAF]
-=======================================================
-
-[Outgoing]
-[q_0000000000000_0000] 3 => 4 (type=HASH_SHUFFLE, key=default.jointable_large.id (INT4),
num=32)
-
-GROUP_BY(17)(id)
-  => exprs: (count())
-  => target list: default.jointable_large.id (INT4), ?count_5 (INT8)
-  => out schema:{(2) default.jointable_large.id (INT4), ?count_5 (INT8)}
-  => in schema:{(1) default.jointable_large.id (INT4)}
-   SCAN(4) on default.jointable_large
-     => filter: default.jointable_large.id (INT4) < 200
-     => target list: default.jointable_large.id (INT4)
-     => out schema: {(1) default.jointable_large.id (INT4)}
-     => in schema: {(2) default.jointable_large.id (INT4), default.jointable_large.name
(TEXT)}
-
-=======================================================
 Block Id: eb_0000000000000_0000_000004 [INTERMEDIATE]
 =======================================================
 

http://git-wip-us.apache.org/repos/asf/tajo/blob/f4680a93/tajo-core/src/test/resources/results/TestOuterJoinWithSubQuery/testJoinWithDifferentShuffleKey.1.Hash_NoBroadcast.plan
----------------------------------------------------------------------
diff --git a/tajo-core/src/test/resources/results/TestOuterJoinWithSubQuery/testJoinWithDifferentShuffleKey.1.Hash_NoBroadcast.plan
b/tajo-core/src/test/resources/results/TestOuterJoinWithSubQuery/testJoinWithDifferentShuffleKey.1.Hash_NoBroadcast.plan
index b9b9adf..f33e844 100644
--- a/tajo-core/src/test/resources/results/TestOuterJoinWithSubQuery/testJoinWithDifferentShuffleKey.1.Hash_NoBroadcast.plan
+++ b/tajo-core/src/test/resources/results/TestOuterJoinWithSubQuery/testJoinWithDifferentShuffleKey.1.Hash_NoBroadcast.plan
@@ -79,6 +79,24 @@ GROUP_BY(15)(id)
      => in schema: {(2) default.jointable_large.id (INT4), default.jointable_large.name
(TEXT)}
 
 =======================================================
+Block Id: eb_0000000000000_0000_000003 [LEAF]
+=======================================================
+
+[Outgoing]
+[q_0000000000000_0000] 3 => 4 (type=HASH_SHUFFLE, key=default.jointable_large.id (INT4),
num=32)
+
+GROUP_BY(17)(id)
+  => exprs: (count())
+  => target list: default.jointable_large.id (INT4), ?count_5 (INT8)
+  => out schema:{(2) default.jointable_large.id (INT4), ?count_5 (INT8)}
+  => in schema:{(1) default.jointable_large.id (INT4)}
+   SCAN(4) on default.jointable_large
+     => filter: default.jointable_large.id (INT4) < 200
+     => target list: default.jointable_large.id (INT4)
+     => out schema: {(1) default.jointable_large.id (INT4)}
+     => in schema: {(2) default.jointable_large.id (INT4), default.jointable_large.name
(TEXT)}
+
+=======================================================
 Block Id: eb_0000000000000_0000_000002 [INTERMEDIATE]
 =======================================================
 
@@ -106,24 +124,6 @@ TABLE_SUBQUERY(3) as default.a
            => in schema: {(2) default.jointable_large.id (INT4), ?count_4 (INT8)}
 
 =======================================================
-Block Id: eb_0000000000000_0000_000003 [LEAF]
-=======================================================
-
-[Outgoing]
-[q_0000000000000_0000] 3 => 4 (type=HASH_SHUFFLE, key=default.jointable_large.id (INT4),
num=32)
-
-GROUP_BY(17)(id)
-  => exprs: (count())
-  => target list: default.jointable_large.id (INT4), ?count_5 (INT8)
-  => out schema:{(2) default.jointable_large.id (INT4), ?count_5 (INT8)}
-  => in schema:{(1) default.jointable_large.id (INT4)}
-   SCAN(4) on default.jointable_large
-     => filter: default.jointable_large.id (INT4) < 200
-     => target list: default.jointable_large.id (INT4)
-     => out schema: {(1) default.jointable_large.id (INT4)}
-     => in schema: {(2) default.jointable_large.id (INT4), default.jointable_large.name
(TEXT)}
-
-=======================================================
 Block Id: eb_0000000000000_0000_000004 [INTERMEDIATE]
 =======================================================
 

http://git-wip-us.apache.org/repos/asf/tajo/blob/f4680a93/tajo-core/src/test/resources/results/TestOuterJoinWithSubQuery/testJoinWithDifferentShuffleKey.1.Sort.plan
----------------------------------------------------------------------
diff --git a/tajo-core/src/test/resources/results/TestOuterJoinWithSubQuery/testJoinWithDifferentShuffleKey.1.Sort.plan
b/tajo-core/src/test/resources/results/TestOuterJoinWithSubQuery/testJoinWithDifferentShuffleKey.1.Sort.plan
index b9b9adf..f33e844 100644
--- a/tajo-core/src/test/resources/results/TestOuterJoinWithSubQuery/testJoinWithDifferentShuffleKey.1.Sort.plan
+++ b/tajo-core/src/test/resources/results/TestOuterJoinWithSubQuery/testJoinWithDifferentShuffleKey.1.Sort.plan
@@ -79,6 +79,24 @@ GROUP_BY(15)(id)
      => in schema: {(2) default.jointable_large.id (INT4), default.jointable_large.name
(TEXT)}
 
 =======================================================
+Block Id: eb_0000000000000_0000_000003 [LEAF]
+=======================================================
+
+[Outgoing]
+[q_0000000000000_0000] 3 => 4 (type=HASH_SHUFFLE, key=default.jointable_large.id (INT4),
num=32)
+
+GROUP_BY(17)(id)
+  => exprs: (count())
+  => target list: default.jointable_large.id (INT4), ?count_5 (INT8)
+  => out schema:{(2) default.jointable_large.id (INT4), ?count_5 (INT8)}
+  => in schema:{(1) default.jointable_large.id (INT4)}
+   SCAN(4) on default.jointable_large
+     => filter: default.jointable_large.id (INT4) < 200
+     => target list: default.jointable_large.id (INT4)
+     => out schema: {(1) default.jointable_large.id (INT4)}
+     => in schema: {(2) default.jointable_large.id (INT4), default.jointable_large.name
(TEXT)}
+
+=======================================================
 Block Id: eb_0000000000000_0000_000002 [INTERMEDIATE]
 =======================================================
 
@@ -106,24 +124,6 @@ TABLE_SUBQUERY(3) as default.a
            => in schema: {(2) default.jointable_large.id (INT4), ?count_4 (INT8)}
 
 =======================================================
-Block Id: eb_0000000000000_0000_000003 [LEAF]
-=======================================================
-
-[Outgoing]
-[q_0000000000000_0000] 3 => 4 (type=HASH_SHUFFLE, key=default.jointable_large.id (INT4),
num=32)
-
-GROUP_BY(17)(id)
-  => exprs: (count())
-  => target list: default.jointable_large.id (INT4), ?count_5 (INT8)
-  => out schema:{(2) default.jointable_large.id (INT4), ?count_5 (INT8)}
-  => in schema:{(1) default.jointable_large.id (INT4)}
-   SCAN(4) on default.jointable_large
-     => filter: default.jointable_large.id (INT4) < 200
-     => target list: default.jointable_large.id (INT4)
-     => out schema: {(1) default.jointable_large.id (INT4)}
-     => in schema: {(2) default.jointable_large.id (INT4), default.jointable_large.name
(TEXT)}
-
-=======================================================
 Block Id: eb_0000000000000_0000_000004 [INTERMEDIATE]
 =======================================================
 

http://git-wip-us.apache.org/repos/asf/tajo/blob/f4680a93/tajo-core/src/test/resources/results/TestOuterJoinWithSubQuery/testJoinWithDifferentShuffleKey.1.Sort_NoBroadcast.plan
----------------------------------------------------------------------
diff --git a/tajo-core/src/test/resources/results/TestOuterJoinWithSubQuery/testJoinWithDifferentShuffleKey.1.Sort_NoBroadcast.plan
b/tajo-core/src/test/resources/results/TestOuterJoinWithSubQuery/testJoinWithDifferentShuffleKey.1.Sort_NoBroadcast.plan
index b9b9adf..f33e844 100644
--- a/tajo-core/src/test/resources/results/TestOuterJoinWithSubQuery/testJoinWithDifferentShuffleKey.1.Sort_NoBroadcast.plan
+++ b/tajo-core/src/test/resources/results/TestOuterJoinWithSubQuery/testJoinWithDifferentShuffleKey.1.Sort_NoBroadcast.plan
@@ -79,6 +79,24 @@ GROUP_BY(15)(id)
      => in schema: {(2) default.jointable_large.id (INT4), default.jointable_large.name
(TEXT)}
 
 =======================================================
+Block Id: eb_0000000000000_0000_000003 [LEAF]
+=======================================================
+
+[Outgoing]
+[q_0000000000000_0000] 3 => 4 (type=HASH_SHUFFLE, key=default.jointable_large.id (INT4),
num=32)
+
+GROUP_BY(17)(id)
+  => exprs: (count())
+  => target list: default.jointable_large.id (INT4), ?count_5 (INT8)
+  => out schema:{(2) default.jointable_large.id (INT4), ?count_5 (INT8)}
+  => in schema:{(1) default.jointable_large.id (INT4)}
+   SCAN(4) on default.jointable_large
+     => filter: default.jointable_large.id (INT4) < 200
+     => target list: default.jointable_large.id (INT4)
+     => out schema: {(1) default.jointable_large.id (INT4)}
+     => in schema: {(2) default.jointable_large.id (INT4), default.jointable_large.name
(TEXT)}
+
+=======================================================
 Block Id: eb_0000000000000_0000_000002 [INTERMEDIATE]
 =======================================================
 
@@ -106,24 +124,6 @@ TABLE_SUBQUERY(3) as default.a
            => in schema: {(2) default.jointable_large.id (INT4), ?count_4 (INT8)}
 
 =======================================================
-Block Id: eb_0000000000000_0000_000003 [LEAF]
-=======================================================
-
-[Outgoing]
-[q_0000000000000_0000] 3 => 4 (type=HASH_SHUFFLE, key=default.jointable_large.id (INT4),
num=32)
-
-GROUP_BY(17)(id)
-  => exprs: (count())
-  => target list: default.jointable_large.id (INT4), ?count_5 (INT8)
-  => out schema:{(2) default.jointable_large.id (INT4), ?count_5 (INT8)}
-  => in schema:{(1) default.jointable_large.id (INT4)}
-   SCAN(4) on default.jointable_large
-     => filter: default.jointable_large.id (INT4) < 200
-     => target list: default.jointable_large.id (INT4)
-     => out schema: {(1) default.jointable_large.id (INT4)}
-     => in schema: {(2) default.jointable_large.id (INT4), default.jointable_large.name
(TEXT)}
-
-=======================================================
 Block Id: eb_0000000000000_0000_000004 [INTERMEDIATE]
 =======================================================
 

http://git-wip-us.apache.org/repos/asf/tajo/blob/f4680a93/tajo-core/src/test/resources/results/TestTPCH/testQ2FourJoins.plan
----------------------------------------------------------------------
diff --git a/tajo-core/src/test/resources/results/TestTPCH/testQ2FourJoins.plan b/tajo-core/src/test/resources/results/TestTPCH/testQ2FourJoins.plan
index a2beae2..ef0f8f8 100644
--- a/tajo-core/src/test/resources/results/TestTPCH/testQ2FourJoins.plan
+++ b/tajo-core/src/test/resources/results/TestTPCH/testQ2FourJoins.plan
@@ -133,29 +133,6 @@ SCAN(7) on default.part
   => in schema: {(9) default.part.p_brand (TEXT), default.part.p_comment (TEXT), default.part.p_container
(TEXT), default.part.p_mfgr (TEXT), default.part.p_name (TEXT), default.part.p_partkey (INT4),
default.part.p_retailprice (FLOAT8), default.part.p_size (INT4), default.part.p_type (TEXT)}
 
 =======================================================
-Block Id: eb_0000000000000_0000_000005 [INTERMEDIATE]
-=======================================================
-
-[Incoming]
-[q_0000000000000_0000] 3 => 5 (type=HASH_SHUFFLE, key=default.partsupp.ps_partkey (INT4),
num=32)
-[q_0000000000000_0000] 4 => 5 (type=HASH_SHUFFLE, key=default.part.p_partkey (INT4), num=32)
-
-[Outgoing]
-[q_0000000000000_0000] 5 => 9 (type=HASH_SHUFFLE, key=default.supplier.s_nationkey (INT4),
num=32)
-
-JOIN(12)(INNER)
-  => Join Cond: default.part.p_partkey (INT4) = default.partsupp.ps_partkey (INT4)
-  => target list: default.part.p_mfgr (TEXT), default.part.p_partkey (INT4), default.part.p_size
(INT4), default.part.p_type (TEXT), default.partsupp.ps_supplycost (FLOAT8), 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)
-  => out schema: {(11) default.part.p_mfgr (TEXT), default.part.p_partkey (INT4), default.part.p_size
(INT4), default.part.p_type (TEXT), default.partsupp.ps_supplycost (FLOAT8), 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)}
-  => in schema: {(12) default.part.p_mfgr (TEXT), default.part.p_partkey (INT4), default.part.p_size
(INT4), default.part.p_type (TEXT), default.partsupp.ps_partkey (INT4), default.partsupp.ps_supplycost
(FLOAT8), 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)}
-   SCAN(19) on eb_0000000000000_0000_000004
-     => out schema: {(4) default.part.p_mfgr (TEXT), default.part.p_partkey (INT4), default.part.p_size
(INT4), default.part.p_type (TEXT)}
-     => in schema: {(4) default.part.p_mfgr (TEXT), default.part.p_partkey (INT4), default.part.p_size
(INT4), default.part.p_type (TEXT)}
-   SCAN(18) on eb_0000000000000_0000_000003
-     => out schema: {(8) default.partsupp.ps_partkey (INT4), default.partsupp.ps_supplycost
(FLOAT8), 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)}
-     => in schema: {(8) default.partsupp.ps_partkey (INT4), default.partsupp.ps_supplycost
(FLOAT8), 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)}
-
-=======================================================
 Block Id: eb_0000000000000_0000_000006 [LEAF]
 =======================================================
 
@@ -181,6 +158,29 @@ SCAN(0) on default.region
   => in schema: {(3) default.region.r_comment (TEXT), default.region.r_name (TEXT), default.region.r_regionkey
(INT4)}
 
 =======================================================
+Block Id: eb_0000000000000_0000_000005 [INTERMEDIATE]
+=======================================================
+
+[Incoming]
+[q_0000000000000_0000] 3 => 5 (type=HASH_SHUFFLE, key=default.partsupp.ps_partkey (INT4),
num=32)
+[q_0000000000000_0000] 4 => 5 (type=HASH_SHUFFLE, key=default.part.p_partkey (INT4), num=32)
+
+[Outgoing]
+[q_0000000000000_0000] 5 => 9 (type=HASH_SHUFFLE, key=default.supplier.s_nationkey (INT4),
num=32)
+
+JOIN(12)(INNER)
+  => Join Cond: default.part.p_partkey (INT4) = default.partsupp.ps_partkey (INT4)
+  => target list: default.part.p_mfgr (TEXT), default.part.p_partkey (INT4), default.part.p_size
(INT4), default.part.p_type (TEXT), default.partsupp.ps_supplycost (FLOAT8), 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)
+  => out schema: {(11) default.part.p_mfgr (TEXT), default.part.p_partkey (INT4), default.part.p_size
(INT4), default.part.p_type (TEXT), default.partsupp.ps_supplycost (FLOAT8), 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)}
+  => in schema: {(12) default.part.p_mfgr (TEXT), default.part.p_partkey (INT4), default.part.p_size
(INT4), default.part.p_type (TEXT), default.partsupp.ps_partkey (INT4), default.partsupp.ps_supplycost
(FLOAT8), 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)}
+   SCAN(19) on eb_0000000000000_0000_000004
+     => out schema: {(4) default.part.p_mfgr (TEXT), default.part.p_partkey (INT4), default.part.p_size
(INT4), default.part.p_type (TEXT)}
+     => in schema: {(4) default.part.p_mfgr (TEXT), default.part.p_partkey (INT4), default.part.p_size
(INT4), default.part.p_type (TEXT)}
+   SCAN(18) on eb_0000000000000_0000_000003
+     => out schema: {(8) default.partsupp.ps_partkey (INT4), default.partsupp.ps_supplycost
(FLOAT8), 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)}
+     => in schema: {(8) default.partsupp.ps_partkey (INT4), default.partsupp.ps_supplycost
(FLOAT8), 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)}
+
+=======================================================
 Block Id: eb_0000000000000_0000_000008 [INTERMEDIATE]
 =======================================================
 

http://git-wip-us.apache.org/repos/asf/tajo/blob/f4680a93/tajo-core/src/test/resources/results/TestTPCH/testTPCHQ5.plan
----------------------------------------------------------------------
diff --git a/tajo-core/src/test/resources/results/TestTPCH/testTPCHQ5.plan b/tajo-core/src/test/resources/results/TestTPCH/testTPCHQ5.plan
index 95abaf1..a466b20 100644
--- a/tajo-core/src/test/resources/results/TestTPCH/testTPCHQ5.plan
+++ b/tajo-core/src/test/resources/results/TestTPCH/testTPCHQ5.plan
@@ -122,29 +122,6 @@ SCAN(1) on default.orders
   => in schema: {(9) 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)}
 
 =======================================================
-Block Id: eb_0000000000000_0000_000003 [INTERMEDIATE]
-=======================================================
-
-[Incoming]
-[q_0000000000000_0000] 1 => 3 (type=HASH_SHUFFLE, key=default.lineitem.l_orderkey (INT4),
num=32)
-[q_0000000000000_0000] 2 => 3 (type=HASH_SHUFFLE, key=default.orders.o_orderkey (INT4),
num=32)
-
-[Outgoing]
-[q_0000000000000_0000] 3 => 7 (type=HASH_SHUFFLE, key=default.lineitem.l_suppkey (INT4),
num=32)
-
-JOIN(16)(INNER)
-  => Join Cond: default.lineitem.l_orderkey (INT4) = default.orders.o_orderkey (INT4)
-  => target list: ?multiply (FLOAT8), default.lineitem.l_discount (FLOAT8), default.lineitem.l_extendedprice
(FLOAT8), default.lineitem.l_suppkey (INT4)
-  => out schema: {(4) ?multiply (FLOAT8), default.lineitem.l_discount (FLOAT8), default.lineitem.l_extendedprice
(FLOAT8), default.lineitem.l_suppkey (INT4)}
-  => in schema: {(6) ?multiply (FLOAT8), default.lineitem.l_discount (FLOAT8), default.lineitem.l_extendedprice
(FLOAT8), default.lineitem.l_orderkey (INT4), default.lineitem.l_suppkey (INT4), default.orders.o_orderkey
(INT4)}
-   SCAN(23) on eb_0000000000000_0000_000002
-     => out schema: {(1) default.orders.o_orderkey (INT4)}
-     => in schema: {(1) default.orders.o_orderkey (INT4)}
-   SCAN(22) on eb_0000000000000_0000_000001
-     => out schema: {(5) ?multiply (FLOAT8), default.lineitem.l_discount (FLOAT8), default.lineitem.l_extendedprice
(FLOAT8), default.lineitem.l_orderkey (INT4), default.lineitem.l_suppkey (INT4)}
-     => in schema: {(5) ?multiply (FLOAT8), default.lineitem.l_discount (FLOAT8), default.lineitem.l_extendedprice
(FLOAT8), default.lineitem.l_orderkey (INT4), default.lineitem.l_suppkey (INT4)}
-
-=======================================================
 Block Id: eb_0000000000000_0000_000004 [LEAF]
 =======================================================
 
@@ -169,6 +146,29 @@ SCAN(0) on default.customer
   => in schema: {(8) default.customer.c_acctbal (FLOAT8), default.customer.c_address (TEXT),
default.customer.c_comment (TEXT), default.customer.c_custkey (INT4), default.customer.c_mktsegment
(TEXT), default.customer.c_name (TEXT), default.customer.c_nationkey (INT4), default.customer.c_phone
(TEXT)}
 
 =======================================================
+Block Id: eb_0000000000000_0000_000003 [INTERMEDIATE]
+=======================================================
+
+[Incoming]
+[q_0000000000000_0000] 1 => 3 (type=HASH_SHUFFLE, key=default.lineitem.l_orderkey (INT4),
num=32)
+[q_0000000000000_0000] 2 => 3 (type=HASH_SHUFFLE, key=default.orders.o_orderkey (INT4),
num=32)
+
+[Outgoing]
+[q_0000000000000_0000] 3 => 7 (type=HASH_SHUFFLE, key=default.lineitem.l_suppkey (INT4),
num=32)
+
+JOIN(16)(INNER)
+  => Join Cond: default.lineitem.l_orderkey (INT4) = default.orders.o_orderkey (INT4)
+  => target list: ?multiply (FLOAT8), default.lineitem.l_discount (FLOAT8), default.lineitem.l_extendedprice
(FLOAT8), default.lineitem.l_suppkey (INT4)
+  => out schema: {(4) ?multiply (FLOAT8), default.lineitem.l_discount (FLOAT8), default.lineitem.l_extendedprice
(FLOAT8), default.lineitem.l_suppkey (INT4)}
+  => in schema: {(6) ?multiply (FLOAT8), default.lineitem.l_discount (FLOAT8), default.lineitem.l_extendedprice
(FLOAT8), default.lineitem.l_orderkey (INT4), default.lineitem.l_suppkey (INT4), default.orders.o_orderkey
(INT4)}
+   SCAN(23) on eb_0000000000000_0000_000002
+     => out schema: {(1) default.orders.o_orderkey (INT4)}
+     => in schema: {(1) default.orders.o_orderkey (INT4)}
+   SCAN(22) on eb_0000000000000_0000_000001
+     => out schema: {(5) ?multiply (FLOAT8), default.lineitem.l_discount (FLOAT8), default.lineitem.l_extendedprice
(FLOAT8), default.lineitem.l_orderkey (INT4), default.lineitem.l_suppkey (INT4)}
+     => in schema: {(5) ?multiply (FLOAT8), default.lineitem.l_discount (FLOAT8), default.lineitem.l_extendedprice
(FLOAT8), default.lineitem.l_orderkey (INT4), default.lineitem.l_suppkey (INT4)}
+
+=======================================================
 Block Id: eb_0000000000000_0000_000006 [INTERMEDIATE]
 =======================================================
 
@@ -192,29 +192,6 @@ JOIN(17)(INNER)
      => in schema: {(2) default.supplier.s_nationkey (INT4), default.supplier.s_suppkey
(INT4)}
 
 =======================================================
-Block Id: eb_0000000000000_0000_000007 [INTERMEDIATE]
-=======================================================
-
-[Incoming]
-[q_0000000000000_0000] 3 => 7 (type=HASH_SHUFFLE, key=default.lineitem.l_suppkey (INT4),
num=32)
-[q_0000000000000_0000] 6 => 7 (type=HASH_SHUFFLE, key=default.supplier.s_suppkey (INT4),
num=32)
-
-[Outgoing]
-[q_0000000000000_0000] 7 => 11 (type=HASH_SHUFFLE, key=default.supplier.s_nationkey (INT4),
num=32)
-
-JOIN(18)(INNER)
-  => Join Cond: default.lineitem.l_suppkey (INT4) = default.supplier.s_suppkey (INT4)
-  => target list: ?multiply (FLOAT8), default.lineitem.l_discount (FLOAT8), default.lineitem.l_extendedprice
(FLOAT8), default.supplier.s_nationkey (INT4)
-  => out schema: {(4) ?multiply (FLOAT8), default.lineitem.l_discount (FLOAT8), default.lineitem.l_extendedprice
(FLOAT8), default.supplier.s_nationkey (INT4)}
-  => in schema: {(6) ?multiply (FLOAT8), default.lineitem.l_discount (FLOAT8), default.lineitem.l_extendedprice
(FLOAT8), default.lineitem.l_suppkey (INT4), default.supplier.s_nationkey (INT4), default.supplier.s_suppkey
(INT4)}
-   SCAN(27) on eb_0000000000000_0000_000006
-     => out schema: {(2) default.supplier.s_nationkey (INT4), default.supplier.s_suppkey
(INT4)}
-     => in schema: {(2) default.supplier.s_nationkey (INT4), default.supplier.s_suppkey
(INT4)}
-   SCAN(26) on eb_0000000000000_0000_000003
-     => out schema: {(4) ?multiply (FLOAT8), default.lineitem.l_discount (FLOAT8), default.lineitem.l_extendedprice
(FLOAT8), default.lineitem.l_suppkey (INT4)}
-     => in schema: {(4) ?multiply (FLOAT8), default.lineitem.l_discount (FLOAT8), default.lineitem.l_extendedprice
(FLOAT8), default.lineitem.l_suppkey (INT4)}
-
-=======================================================
 Block Id: eb_0000000000000_0000_000008 [LEAF]
 =======================================================
 
@@ -240,6 +217,29 @@ SCAN(5) on default.region
   => in schema: {(3) default.region.r_comment (TEXT), default.region.r_name (TEXT), default.region.r_regionkey
(INT4)}
 
 =======================================================
+Block Id: eb_0000000000000_0000_000007 [INTERMEDIATE]
+=======================================================
+
+[Incoming]
+[q_0000000000000_0000] 3 => 7 (type=HASH_SHUFFLE, key=default.lineitem.l_suppkey (INT4),
num=32)
+[q_0000000000000_0000] 6 => 7 (type=HASH_SHUFFLE, key=default.supplier.s_suppkey (INT4),
num=32)
+
+[Outgoing]
+[q_0000000000000_0000] 7 => 11 (type=HASH_SHUFFLE, key=default.supplier.s_nationkey (INT4),
num=32)
+
+JOIN(18)(INNER)
+  => Join Cond: default.lineitem.l_suppkey (INT4) = default.supplier.s_suppkey (INT4)
+  => target list: ?multiply (FLOAT8), default.lineitem.l_discount (FLOAT8), default.lineitem.l_extendedprice
(FLOAT8), default.supplier.s_nationkey (INT4)
+  => out schema: {(4) ?multiply (FLOAT8), default.lineitem.l_discount (FLOAT8), default.lineitem.l_extendedprice
(FLOAT8), default.supplier.s_nationkey (INT4)}
+  => in schema: {(6) ?multiply (FLOAT8), default.lineitem.l_discount (FLOAT8), default.lineitem.l_extendedprice
(FLOAT8), default.lineitem.l_suppkey (INT4), default.supplier.s_nationkey (INT4), default.supplier.s_suppkey
(INT4)}
+   SCAN(27) on eb_0000000000000_0000_000006
+     => out schema: {(2) default.supplier.s_nationkey (INT4), default.supplier.s_suppkey
(INT4)}
+     => in schema: {(2) default.supplier.s_nationkey (INT4), default.supplier.s_suppkey
(INT4)}
+   SCAN(26) on eb_0000000000000_0000_000003
+     => out schema: {(4) ?multiply (FLOAT8), default.lineitem.l_discount (FLOAT8), default.lineitem.l_extendedprice
(FLOAT8), default.lineitem.l_suppkey (INT4)}
+     => in schema: {(4) ?multiply (FLOAT8), default.lineitem.l_discount (FLOAT8), default.lineitem.l_extendedprice
(FLOAT8), default.lineitem.l_suppkey (INT4)}
+
+=======================================================
 Block Id: eb_0000000000000_0000_000010 [INTERMEDIATE]
 =======================================================
 


Mime
View raw message