[13/17] tajo git commit: TAJO-1352: Improve the join order algorithm to consider missed cases of associative join operators. (jihoon)

[jihoonson]

http://git-wip-us.apache.org/repos/asf/tajo/blob/bedce3aa/tajo-core/src/test/resources/results/TestInnerJoinQuery/testJoinAsterisk.Sort.plan
----------------------------------------------------------------------
diff --git 
a/tajo-core/src/test/resources/results/TestInnerJoinQuery/testJoinAsterisk.Sort.plan
 
b/tajo-core/src/test/resources/results/TestInnerJoinQuery/testJoinAsterisk.Sort.plan
index 244bfa9..0120a2b 100644
--- 
a/tajo-core/src/test/resources/results/TestInnerJoinQuery/testJoinAsterisk.Sort.plan
+++ 
b/tajo-core/src/test/resources/results/TestInnerJoinQuery/testJoinAsterisk.Sort.plan
@@ -5,14 +5,14 @@ JOIN(5)(INNER)
   => target list: default.a.c_acctbal (FLOAT8), default.a.c_address (TEXT), 
default.a.c_comment (TEXT), default.a.c_custkey (INT4), default.a.c_mktsegment 
(TEXT), default.a.c_name (TEXT), default.a.c_nationkey (INT4), 
default.a.c_phone (TEXT), default.b.n_comment (TEXT), default.b.n_name (TEXT), 
default.b.n_nationkey (INT4), default.b.n_regionkey (INT4)
   => out schema: {(12) default.a.c_acctbal (FLOAT8), default.a.c_address 
(TEXT), default.a.c_comment (TEXT), default.a.c_custkey (INT4), 
default.a.c_mktsegment (TEXT), default.a.c_name (TEXT), default.a.c_nationkey 
(INT4), default.a.c_phone (TEXT), default.b.n_comment (TEXT), default.b.n_name 
(TEXT), default.b.n_nationkey (INT4), default.b.n_regionkey (INT4)}
   => in schema: {(12) default.a.c_acctbal (FLOAT8), default.a.c_address 
(TEXT), default.a.c_comment (TEXT), default.a.c_custkey (INT4), 
default.a.c_mktsegment (TEXT), default.a.c_name (TEXT), default.a.c_nationkey 
(INT4), default.a.c_phone (TEXT), default.b.n_comment (TEXT), default.b.n_name 
(TEXT), default.b.n_nationkey (INT4), default.b.n_regionkey (INT4)}
-   SCAN(0) on default.nation as b
-     => target list: default.b.n_comment (TEXT), default.b.n_name (TEXT), 
default.b.n_nationkey (INT4), default.b.n_regionkey (INT4)
-     => out schema: {(4) default.b.n_comment (TEXT), default.b.n_name (TEXT), 
default.b.n_nationkey (INT4), 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)}
    SCAN(1) on default.customer as a
      => target list: default.a.c_acctbal (FLOAT8), default.a.c_address (TEXT), 
default.a.c_comment (TEXT), default.a.c_custkey (INT4), default.a.c_mktsegment 
(TEXT), default.a.c_name (TEXT), default.a.c_nationkey (INT4), 
default.a.c_phone (TEXT)
      => out schema: {(8) default.a.c_acctbal (FLOAT8), default.a.c_address 
(TEXT), default.a.c_comment (TEXT), default.a.c_custkey (INT4), 
default.a.c_mktsegment (TEXT), default.a.c_name (TEXT), default.a.c_nationkey 
(INT4), default.a.c_phone (TEXT)}
      => in schema: {(8) default.a.c_acctbal (FLOAT8), default.a.c_address 
(TEXT), default.a.c_comment (TEXT), default.a.c_custkey (INT4), 
default.a.c_mktsegment (TEXT), default.a.c_name (TEXT), default.a.c_nationkey 
(INT4), default.a.c_phone (TEXT)}
+   SCAN(0) on default.nation as b
+     => target list: default.b.n_comment (TEXT), default.b.n_name (TEXT), 
default.b.n_nationkey (INT4), default.b.n_regionkey (INT4)
+     => out schema: {(4) default.b.n_comment (TEXT), default.b.n_name (TEXT), 
default.b.n_nationkey (INT4), 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
 -------------------------------
 -------------------------------------------------------------------------------
@@ -39,14 +39,14 @@ JOIN(5)(INNER)
   => target list: default.a.c_acctbal (FLOAT8), default.a.c_address (TEXT), 
default.a.c_comment (TEXT), default.a.c_custkey (INT4), default.a.c_mktsegment 
(TEXT), default.a.c_name (TEXT), default.a.c_nationkey (INT4), 
default.a.c_phone (TEXT), default.b.n_comment (TEXT), default.b.n_name (TEXT), 
default.b.n_nationkey (INT4), default.b.n_regionkey (INT4)
   => out schema: {(12) default.a.c_acctbal (FLOAT8), default.a.c_address 
(TEXT), default.a.c_comment (TEXT), default.a.c_custkey (INT4), 
default.a.c_mktsegment (TEXT), default.a.c_name (TEXT), default.a.c_nationkey 
(INT4), default.a.c_phone (TEXT), default.b.n_comment (TEXT), default.b.n_name 
(TEXT), default.b.n_nationkey (INT4), default.b.n_regionkey (INT4)}
   => in schema: {(12) default.a.c_acctbal (FLOAT8), default.a.c_address 
(TEXT), default.a.c_comment (TEXT), default.a.c_custkey (INT4), 
default.a.c_mktsegment (TEXT), default.a.c_name (TEXT), default.a.c_nationkey 
(INT4), default.a.c_phone (TEXT), default.b.n_comment (TEXT), default.b.n_name 
(TEXT), default.b.n_nationkey (INT4), default.b.n_regionkey (INT4)}
-   SCAN(0) on default.nation as b
-     => target list: default.b.n_comment (TEXT), default.b.n_name (TEXT), 
default.b.n_nationkey (INT4), default.b.n_regionkey (INT4)
-     => out schema: {(4) default.b.n_comment (TEXT), default.b.n_name (TEXT), 
default.b.n_nationkey (INT4), 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)}
    SCAN(1) on default.customer as a
      => target list: default.a.c_acctbal (FLOAT8), default.a.c_address (TEXT), 
default.a.c_comment (TEXT), default.a.c_custkey (INT4), default.a.c_mktsegment 
(TEXT), default.a.c_name (TEXT), default.a.c_nationkey (INT4), 
default.a.c_phone (TEXT)
      => out schema: {(8) default.a.c_acctbal (FLOAT8), default.a.c_address 
(TEXT), default.a.c_comment (TEXT), default.a.c_custkey (INT4), 
default.a.c_mktsegment (TEXT), default.a.c_name (TEXT), default.a.c_nationkey 
(INT4), default.a.c_phone (TEXT)}
      => in schema: {(8) default.a.c_acctbal (FLOAT8), default.a.c_address 
(TEXT), default.a.c_comment (TEXT), default.a.c_custkey (INT4), 
default.a.c_mktsegment (TEXT), default.a.c_name (TEXT), default.a.c_nationkey 
(INT4), default.a.c_phone (TEXT)}
+   SCAN(0) on default.nation as b
+     => target list: default.b.n_comment (TEXT), default.b.n_name (TEXT), 
default.b.n_nationkey (INT4), default.b.n_regionkey (INT4)
+     => out schema: {(4) default.b.n_comment (TEXT), default.b.n_name (TEXT), 
default.b.n_nationkey (INT4), 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/bedce3aa/tajo-core/src/test/resources/results/TestInnerJoinQuery/testJoinAsterisk.Sort_NoBroadcast.plan
----------------------------------------------------------------------
diff --git 
a/tajo-core/src/test/resources/results/TestInnerJoinQuery/testJoinAsterisk.Sort_NoBroadcast.plan
 
b/tajo-core/src/test/resources/results/TestInnerJoinQuery/testJoinAsterisk.Sort_NoBroadcast.plan
index f5ee800..afc6b06 100644
--- 
a/tajo-core/src/test/resources/results/TestInnerJoinQuery/testJoinAsterisk.Sort_NoBroadcast.plan
+++ 
b/tajo-core/src/test/resources/results/TestInnerJoinQuery/testJoinAsterisk.Sort_NoBroadcast.plan
@@ -5,14 +5,14 @@ JOIN(5)(INNER)
   => target list: default.a.c_acctbal (FLOAT8), default.a.c_address (TEXT), 
default.a.c_comment (TEXT), default.a.c_custkey (INT4), default.a.c_mktsegment 
(TEXT), default.a.c_name (TEXT), default.a.c_nationkey (INT4), 
default.a.c_phone (TEXT), default.b.n_comment (TEXT), default.b.n_name (TEXT), 
default.b.n_nationkey (INT4), default.b.n_regionkey (INT4)
   => out schema: {(12) default.a.c_acctbal (FLOAT8), default.a.c_address 
(TEXT), default.a.c_comment (TEXT), default.a.c_custkey (INT4), 
default.a.c_mktsegment (TEXT), default.a.c_name (TEXT), default.a.c_nationkey 
(INT4), default.a.c_phone (TEXT), default.b.n_comment (TEXT), default.b.n_name 
(TEXT), default.b.n_nationkey (INT4), default.b.n_regionkey (INT4)}
   => in schema: {(12) default.a.c_acctbal (FLOAT8), default.a.c_address 
(TEXT), default.a.c_comment (TEXT), default.a.c_custkey (INT4), 
default.a.c_mktsegment (TEXT), default.a.c_name (TEXT), default.a.c_nationkey 
(INT4), default.a.c_phone (TEXT), default.b.n_comment (TEXT), default.b.n_name 
(TEXT), default.b.n_nationkey (INT4), default.b.n_regionkey (INT4)}
-   SCAN(0) on default.nation as b
-     => target list: default.b.n_comment (TEXT), default.b.n_name (TEXT), 
default.b.n_nationkey (INT4), default.b.n_regionkey (INT4)
-     => out schema: {(4) default.b.n_comment (TEXT), default.b.n_name (TEXT), 
default.b.n_nationkey (INT4), 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)}
    SCAN(1) on default.customer as a
      => target list: default.a.c_acctbal (FLOAT8), default.a.c_address (TEXT), 
default.a.c_comment (TEXT), default.a.c_custkey (INT4), default.a.c_mktsegment 
(TEXT), default.a.c_name (TEXT), default.a.c_nationkey (INT4), 
default.a.c_phone (TEXT)
      => out schema: {(8) default.a.c_acctbal (FLOAT8), default.a.c_address 
(TEXT), default.a.c_comment (TEXT), default.a.c_custkey (INT4), 
default.a.c_mktsegment (TEXT), default.a.c_name (TEXT), default.a.c_nationkey 
(INT4), default.a.c_phone (TEXT)}
      => in schema: {(8) default.a.c_acctbal (FLOAT8), default.a.c_address 
(TEXT), default.a.c_comment (TEXT), default.a.c_custkey (INT4), 
default.a.c_mktsegment (TEXT), default.a.c_name (TEXT), default.a.c_nationkey 
(INT4), default.a.c_phone (TEXT)}
+   SCAN(0) on default.nation as b
+     => target list: default.b.n_comment (TEXT), default.b.n_name (TEXT), 
default.b.n_nationkey (INT4), default.b.n_regionkey (INT4)
+     => out schema: {(4) default.b.n_comment (TEXT), default.b.n_name (TEXT), 
default.b.n_nationkey (INT4), 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
 -------------------------------
 -------------------------------------------------------------------------------
@@ -36,32 +36,32 @@ Block Id: eb_0000000000000_0000_000001 [LEAF]
 =======================================================
 
 [Outgoing]
-[q_0000000000000_0000] 1 => 3 (type=HASH_SHUFFLE, key=default.a.c_nationkey 
(INT4), num=32)
+[q_0000000000000_0000] 1 => 3 (type=HASH_SHUFFLE, key=default.b.n_nationkey 
(INT4), num=32)
 
-SCAN(1) on default.customer as a
-  => target list: default.a.c_acctbal (FLOAT8), default.a.c_address (TEXT), 
default.a.c_comment (TEXT), default.a.c_custkey (INT4), default.a.c_mktsegment 
(TEXT), default.a.c_name (TEXT), default.a.c_nationkey (INT4), 
default.a.c_phone (TEXT)
-  => out schema: {(8) default.a.c_acctbal (FLOAT8), default.a.c_address 
(TEXT), default.a.c_comment (TEXT), default.a.c_custkey (INT4), 
default.a.c_mktsegment (TEXT), default.a.c_name (TEXT), default.a.c_nationkey 
(INT4), default.a.c_phone (TEXT)}
-  => in schema: {(8) default.a.c_acctbal (FLOAT8), default.a.c_address (TEXT), 
default.a.c_comment (TEXT), default.a.c_custkey (INT4), default.a.c_mktsegment 
(TEXT), default.a.c_name (TEXT), default.a.c_nationkey (INT4), 
default.a.c_phone (TEXT)}
+SCAN(0) on default.nation as b
+  => target list: default.b.n_comment (TEXT), default.b.n_name (TEXT), 
default.b.n_nationkey (INT4), default.b.n_regionkey (INT4)
+  => out schema: {(4) default.b.n_comment (TEXT), default.b.n_name (TEXT), 
default.b.n_nationkey (INT4), 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]
 =======================================================
 
 [Outgoing]
-[q_0000000000000_0000] 2 => 3 (type=HASH_SHUFFLE, key=default.b.n_nationkey 
(INT4), num=32)
+[q_0000000000000_0000] 2 => 3 (type=HASH_SHUFFLE, key=default.a.c_nationkey 
(INT4), num=32)
 
-SCAN(0) on default.nation as b
-  => target list: default.b.n_comment (TEXT), default.b.n_name (TEXT), 
default.b.n_nationkey (INT4), default.b.n_regionkey (INT4)
-  => out schema: {(4) default.b.n_comment (TEXT), default.b.n_name (TEXT), 
default.b.n_nationkey (INT4), 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)}
+SCAN(1) on default.customer as a
+  => target list: default.a.c_acctbal (FLOAT8), default.a.c_address (TEXT), 
default.a.c_comment (TEXT), default.a.c_custkey (INT4), default.a.c_mktsegment 
(TEXT), default.a.c_name (TEXT), default.a.c_nationkey (INT4), 
default.a.c_phone (TEXT)
+  => out schema: {(8) default.a.c_acctbal (FLOAT8), default.a.c_address 
(TEXT), default.a.c_comment (TEXT), default.a.c_custkey (INT4), 
default.a.c_mktsegment (TEXT), default.a.c_name (TEXT), default.a.c_nationkey 
(INT4), default.a.c_phone (TEXT)}
+  => in schema: {(8) default.a.c_acctbal (FLOAT8), default.a.c_address (TEXT), 
default.a.c_comment (TEXT), default.a.c_custkey (INT4), default.a.c_mktsegment 
(TEXT), default.a.c_name (TEXT), default.a.c_nationkey (INT4), 
default.a.c_phone (TEXT)}
 
 =======================================================
 Block Id: eb_0000000000000_0000_000003 [ROOT]
 =======================================================
 
 [Incoming]
-[q_0000000000000_0000] 1 => 3 (type=HASH_SHUFFLE, key=default.a.c_nationkey 
(INT4), num=32)
-[q_0000000000000_0000] 2 => 3 (type=HASH_SHUFFLE, key=default.b.n_nationkey 
(INT4), num=32)
+[q_0000000000000_0000] 1 => 3 (type=HASH_SHUFFLE, key=default.b.n_nationkey 
(INT4), num=32)
+[q_0000000000000_0000] 2 => 3 (type=HASH_SHUFFLE, key=default.a.c_nationkey 
(INT4), num=32)
 
 JOIN(5)(INNER)
   => Join Cond: default.b.n_nationkey (INT4) = default.a.c_nationkey (INT4)
@@ -69,11 +69,11 @@ JOIN(5)(INNER)
   => out schema: {(12) default.a.c_acctbal (FLOAT8), default.a.c_address 
(TEXT), default.a.c_comment (TEXT), default.a.c_custkey (INT4), 
default.a.c_mktsegment (TEXT), default.a.c_name (TEXT), default.a.c_nationkey 
(INT4), default.a.c_phone (TEXT), default.b.n_comment (TEXT), default.b.n_name 
(TEXT), default.b.n_nationkey (INT4), default.b.n_regionkey (INT4)}
   => in schema: {(12) default.a.c_acctbal (FLOAT8), default.a.c_address 
(TEXT), default.a.c_comment (TEXT), default.a.c_custkey (INT4), 
default.a.c_mktsegment (TEXT), default.a.c_name (TEXT), default.a.c_nationkey 
(INT4), default.a.c_phone (TEXT), default.b.n_comment (TEXT), default.b.n_name 
(TEXT), default.b.n_nationkey (INT4), default.b.n_regionkey (INT4)}
    SCAN(8) on eb_0000000000000_0000_000002
-     => out schema: {(4) default.b.n_comment (TEXT), default.b.n_name (TEXT), 
default.b.n_nationkey (INT4), 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)}
-   SCAN(7) on eb_0000000000000_0000_000001
      => out schema: {(8) default.a.c_acctbal (FLOAT8), default.a.c_address 
(TEXT), default.a.c_comment (TEXT), default.a.c_custkey (INT4), 
default.a.c_mktsegment (TEXT), default.a.c_name (TEXT), default.a.c_nationkey 
(INT4), default.a.c_phone (TEXT)}
      => in schema: {(8) default.a.c_acctbal (FLOAT8), default.a.c_address 
(TEXT), default.a.c_comment (TEXT), default.a.c_custkey (INT4), 
default.a.c_mktsegment (TEXT), default.a.c_name (TEXT), default.a.c_nationkey 
(INT4), default.a.c_phone (TEXT)}
+   SCAN(7) on eb_0000000000000_0000_000001
+     => out schema: {(4) default.b.n_comment (TEXT), default.b.n_name (TEXT), 
default.b.n_nationkey (INT4), 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/bedce3aa/tajo-core/src/test/resources/results/TestInnerJoinQuery/testJoinCoReferredEvals1.Hash.plan
----------------------------------------------------------------------
diff --git 
a/tajo-core/src/test/resources/results/TestInnerJoinQuery/testJoinCoReferredEvals1.Hash.plan
 
b/tajo-core/src/test/resources/results/TestInnerJoinQuery/testJoinCoReferredEvals1.Hash.plan
index d5e2b9b..21e765d 100644
--- 
a/tajo-core/src/test/resources/results/TestInnerJoinQuery/testJoinCoReferredEvals1.Hash.plan
+++ 
b/tajo-core/src/test/resources/results/TestInnerJoinQuery/testJoinCoReferredEvals1.Hash.plan
@@ -7,14 +7,14 @@ SORT(3)
      => target list: default.nation.n_regionkey (INT4), 
default.region.r_regionkey (INT4), default.region.r_regionkey (INT4) + 
default.nation.n_regionkey (INT4) as plus
      => out schema: {(3) default.nation.n_regionkey (INT4), 
default.region.r_regionkey (INT4), plus (INT4)}
      => in schema: {(2) default.nation.n_regionkey (INT4), 
default.region.r_regionkey (INT4)}
-      SCAN(1) on default.nation
-        => target list: default.nation.n_regionkey (INT4)
-        => out schema: {(1) default.nation.n_regionkey (INT4)}
-        => in schema: {(4) default.nation.n_comment (TEXT), 
default.nation.n_name (TEXT), default.nation.n_nationkey (INT4), 
default.nation.n_regionkey (INT4)}
       SCAN(0) on default.region
         => target list: default.region.r_regionkey (INT4)
         => out schema: {(1) default.region.r_regionkey (INT4)}
         => in schema: {(3) default.region.r_comment (TEXT), 
default.region.r_name (TEXT), default.region.r_regionkey (INT4)}
+      SCAN(1) on default.nation
+        => target list: default.nation.n_regionkey (INT4)
+        => out schema: {(1) default.nation.n_regionkey (INT4)}
+        => in schema: {(4) default.nation.n_comment (TEXT), 
default.nation.n_name (TEXT), default.nation.n_nationkey (INT4), 
default.nation.n_regionkey (INT4)}
 explain
 -------------------------------
 -------------------------------------------------------------------------------
@@ -48,14 +48,14 @@ SORT(11)
      => target list: default.nation.n_regionkey (INT4), 
default.region.r_regionkey (INT4), default.region.r_regionkey (INT4) + 
default.nation.n_regionkey (INT4) as plus
      => out schema: {(3) default.nation.n_regionkey (INT4), 
default.region.r_regionkey (INT4), plus (INT4)}
      => in schema: {(2) default.nation.n_regionkey (INT4), 
default.region.r_regionkey (INT4)}
-      SCAN(1) on default.nation
-        => target list: default.nation.n_regionkey (INT4)
-        => out schema: {(1) default.nation.n_regionkey (INT4)}
-        => in schema: {(4) default.nation.n_comment (TEXT), 
default.nation.n_name (TEXT), default.nation.n_nationkey (INT4), 
default.nation.n_regionkey (INT4)}
       SCAN(0) on default.region
         => target list: default.region.r_regionkey (INT4)
         => out schema: {(1) default.region.r_regionkey (INT4)}
         => in schema: {(3) default.region.r_comment (TEXT), 
default.region.r_name (TEXT), default.region.r_regionkey (INT4)}
+      SCAN(1) on default.nation
+        => target list: default.nation.n_regionkey (INT4)
+        => out schema: {(1) default.nation.n_regionkey (INT4)}
+        => in schema: {(4) default.nation.n_comment (TEXT), 
default.nation.n_name (TEXT), default.nation.n_nationkey (INT4), 
default.nation.n_regionkey (INT4)}
 
 =======================================================
 Block Id: eb_0000000000000_0000_000004 [ROOT]

http://git-wip-us.apache.org/repos/asf/tajo/blob/bedce3aa/tajo-core/src/test/resources/results/TestInnerJoinQuery/testJoinCoReferredEvals1.Hash_NoBroadcast.plan
----------------------------------------------------------------------
diff --git 
a/tajo-core/src/test/resources/results/TestInnerJoinQuery/testJoinCoReferredEvals1.Hash_NoBroadcast.plan
 
b/tajo-core/src/test/resources/results/TestInnerJoinQuery/testJoinCoReferredEvals1.Hash_NoBroadcast.plan
index ea4afb6..4250b5c 100644
--- 
a/tajo-core/src/test/resources/results/TestInnerJoinQuery/testJoinCoReferredEvals1.Hash_NoBroadcast.plan
+++ 
b/tajo-core/src/test/resources/results/TestInnerJoinQuery/testJoinCoReferredEvals1.Hash_NoBroadcast.plan
@@ -7,14 +7,14 @@ SORT(3)
      => target list: default.nation.n_regionkey (INT4), 
default.region.r_regionkey (INT4), default.region.r_regionkey (INT4) + 
default.nation.n_regionkey (INT4) as plus
      => out schema: {(3) default.nation.n_regionkey (INT4), 
default.region.r_regionkey (INT4), plus (INT4)}
      => in schema: {(2) default.nation.n_regionkey (INT4), 
default.region.r_regionkey (INT4)}
-      SCAN(1) on default.nation
-        => target list: default.nation.n_regionkey (INT4)
-        => out schema: {(1) default.nation.n_regionkey (INT4)}
-        => in schema: {(4) default.nation.n_comment (TEXT), 
default.nation.n_name (TEXT), default.nation.n_nationkey (INT4), 
default.nation.n_regionkey (INT4)}
       SCAN(0) on default.region
         => target list: default.region.r_regionkey (INT4)
         => out schema: {(1) default.region.r_regionkey (INT4)}
         => in schema: {(3) default.region.r_comment (TEXT), 
default.region.r_name (TEXT), default.region.r_regionkey (INT4)}
+      SCAN(1) on default.nation
+        => target list: default.nation.n_regionkey (INT4)
+        => out schema: {(1) default.nation.n_regionkey (INT4)}
+        => in schema: {(4) default.nation.n_comment (TEXT), 
default.nation.n_name (TEXT), default.nation.n_nationkey (INT4), 
default.nation.n_regionkey (INT4)}
 explain
 -------------------------------
 -------------------------------------------------------------------------------
@@ -40,32 +40,32 @@ Block Id: eb_0000000000000_0000_000001 [LEAF]
 =======================================================
 
 [Outgoing]
-[q_0000000000000_0000] 1 => 3 (type=HASH_SHUFFLE, 
key=default.region.r_regionkey (INT4), num=32)
+[q_0000000000000_0000] 1 => 3 (type=HASH_SHUFFLE, 
key=default.nation.n_regionkey (INT4), num=32)
 
-SCAN(0) on default.region
-  => target list: default.region.r_regionkey (INT4)
-  => out schema: {(1) default.region.r_regionkey (INT4)}
-  => in schema: {(3) default.region.r_comment (TEXT), default.region.r_name 
(TEXT), default.region.r_regionkey (INT4)}
+SCAN(1) on default.nation
+  => target list: default.nation.n_regionkey (INT4)
+  => out schema: {(1) default.nation.n_regionkey (INT4)}
+  => in schema: {(4) default.nation.n_comment (TEXT), default.nation.n_name 
(TEXT), default.nation.n_nationkey (INT4), default.nation.n_regionkey (INT4)}
 
 =======================================================
 Block Id: eb_0000000000000_0000_000002 [LEAF]
 =======================================================
 
 [Outgoing]
-[q_0000000000000_0000] 2 => 3 (type=HASH_SHUFFLE, 
key=default.nation.n_regionkey (INT4), num=32)
+[q_0000000000000_0000] 2 => 3 (type=HASH_SHUFFLE, 
key=default.region.r_regionkey (INT4), num=32)
 
-SCAN(1) on default.nation
-  => target list: default.nation.n_regionkey (INT4)
-  => out schema: {(1) default.nation.n_regionkey (INT4)}
-  => in schema: {(4) default.nation.n_comment (TEXT), default.nation.n_name 
(TEXT), default.nation.n_nationkey (INT4), default.nation.n_regionkey (INT4)}
+SCAN(0) on default.region
+  => target list: default.region.r_regionkey (INT4)
+  => out schema: {(1) default.region.r_regionkey (INT4)}
+  => in schema: {(3) default.region.r_comment (TEXT), default.region.r_name 
(TEXT), default.region.r_regionkey (INT4)}
 
 =======================================================
 Block Id: eb_0000000000000_0000_000003 [INTERMEDIATE]
 =======================================================
 
 [Incoming]
-[q_0000000000000_0000] 1 => 3 (type=HASH_SHUFFLE, 
key=default.region.r_regionkey (INT4), num=32)
-[q_0000000000000_0000] 2 => 3 (type=HASH_SHUFFLE, 
key=default.nation.n_regionkey (INT4), num=32)
+[q_0000000000000_0000] 1 => 3 (type=HASH_SHUFFLE, 
key=default.nation.n_regionkey (INT4), num=32)
+[q_0000000000000_0000] 2 => 3 (type=HASH_SHUFFLE, 
key=default.region.r_regionkey (INT4), num=32)
 
 [Outgoing]
 [q_0000000000000_0000] 3 => 4 (type=RANGE_SHUFFLE, 
key=default.nation.n_regionkey (INT4), default.region.r_regionkey (INT4), 
num=32)
@@ -78,11 +78,11 @@ SORT(11)
      => out schema: {(3) default.nation.n_regionkey (INT4), 
default.region.r_regionkey (INT4), plus (INT4)}
      => in schema: {(2) default.nation.n_regionkey (INT4), 
default.region.r_regionkey (INT4)}
       SCAN(10) on eb_0000000000000_0000_000002
-        => out schema: {(1) default.nation.n_regionkey (INT4)}
-        => in schema: {(1) default.nation.n_regionkey (INT4)}
-      SCAN(9) on eb_0000000000000_0000_000001
         => out schema: {(1) default.region.r_regionkey (INT4)}
         => in schema: {(1) default.region.r_regionkey (INT4)}
+      SCAN(9) on eb_0000000000000_0000_000001
+        => out schema: {(1) default.nation.n_regionkey (INT4)}
+        => in schema: {(1) default.nation.n_regionkey (INT4)}
 
 =======================================================
 Block Id: eb_0000000000000_0000_000004 [ROOT]

http://git-wip-us.apache.org/repos/asf/tajo/blob/bedce3aa/tajo-core/src/test/resources/results/TestInnerJoinQuery/testJoinCoReferredEvals1.Sort.plan
----------------------------------------------------------------------
diff --git 
a/tajo-core/src/test/resources/results/TestInnerJoinQuery/testJoinCoReferredEvals1.Sort.plan
 
b/tajo-core/src/test/resources/results/TestInnerJoinQuery/testJoinCoReferredEvals1.Sort.plan
index d5e2b9b..21e765d 100644
--- 
a/tajo-core/src/test/resources/results/TestInnerJoinQuery/testJoinCoReferredEvals1.Sort.plan
+++ 
b/tajo-core/src/test/resources/results/TestInnerJoinQuery/testJoinCoReferredEvals1.Sort.plan
@@ -7,14 +7,14 @@ SORT(3)
      => target list: default.nation.n_regionkey (INT4), 
default.region.r_regionkey (INT4), default.region.r_regionkey (INT4) + 
default.nation.n_regionkey (INT4) as plus
      => out schema: {(3) default.nation.n_regionkey (INT4), 
default.region.r_regionkey (INT4), plus (INT4)}
      => in schema: {(2) default.nation.n_regionkey (INT4), 
default.region.r_regionkey (INT4)}
-      SCAN(1) on default.nation
-        => target list: default.nation.n_regionkey (INT4)
-        => out schema: {(1) default.nation.n_regionkey (INT4)}
-        => in schema: {(4) default.nation.n_comment (TEXT), 
default.nation.n_name (TEXT), default.nation.n_nationkey (INT4), 
default.nation.n_regionkey (INT4)}
       SCAN(0) on default.region
         => target list: default.region.r_regionkey (INT4)
         => out schema: {(1) default.region.r_regionkey (INT4)}
         => in schema: {(3) default.region.r_comment (TEXT), 
default.region.r_name (TEXT), default.region.r_regionkey (INT4)}
+      SCAN(1) on default.nation
+        => target list: default.nation.n_regionkey (INT4)
+        => out schema: {(1) default.nation.n_regionkey (INT4)}
+        => in schema: {(4) default.nation.n_comment (TEXT), 
default.nation.n_name (TEXT), default.nation.n_nationkey (INT4), 
default.nation.n_regionkey (INT4)}
 explain
 -------------------------------
 -------------------------------------------------------------------------------
@@ -48,14 +48,14 @@ SORT(11)
      => target list: default.nation.n_regionkey (INT4), 
default.region.r_regionkey (INT4), default.region.r_regionkey (INT4) + 
default.nation.n_regionkey (INT4) as plus
      => out schema: {(3) default.nation.n_regionkey (INT4), 
default.region.r_regionkey (INT4), plus (INT4)}
      => in schema: {(2) default.nation.n_regionkey (INT4), 
default.region.r_regionkey (INT4)}
-      SCAN(1) on default.nation
-        => target list: default.nation.n_regionkey (INT4)
-        => out schema: {(1) default.nation.n_regionkey (INT4)}
-        => in schema: {(4) default.nation.n_comment (TEXT), 
default.nation.n_name (TEXT), default.nation.n_nationkey (INT4), 
default.nation.n_regionkey (INT4)}
       SCAN(0) on default.region
         => target list: default.region.r_regionkey (INT4)
         => out schema: {(1) default.region.r_regionkey (INT4)}
         => in schema: {(3) default.region.r_comment (TEXT), 
default.region.r_name (TEXT), default.region.r_regionkey (INT4)}
+      SCAN(1) on default.nation
+        => target list: default.nation.n_regionkey (INT4)
+        => out schema: {(1) default.nation.n_regionkey (INT4)}
+        => in schema: {(4) default.nation.n_comment (TEXT), 
default.nation.n_name (TEXT), default.nation.n_nationkey (INT4), 
default.nation.n_regionkey (INT4)}
 
 =======================================================
 Block Id: eb_0000000000000_0000_000004 [ROOT]

http://git-wip-us.apache.org/repos/asf/tajo/blob/bedce3aa/tajo-core/src/test/resources/results/TestInnerJoinQuery/testJoinCoReferredEvals1.Sort_NoBroadcast.plan
----------------------------------------------------------------------
diff --git 
a/tajo-core/src/test/resources/results/TestInnerJoinQuery/testJoinCoReferredEvals1.Sort_NoBroadcast.plan
 
b/tajo-core/src/test/resources/results/TestInnerJoinQuery/testJoinCoReferredEvals1.Sort_NoBroadcast.plan
index ea4afb6..4250b5c 100644
--- 
a/tajo-core/src/test/resources/results/TestInnerJoinQuery/testJoinCoReferredEvals1.Sort_NoBroadcast.plan
+++ 
b/tajo-core/src/test/resources/results/TestInnerJoinQuery/testJoinCoReferredEvals1.Sort_NoBroadcast.plan
@@ -7,14 +7,14 @@ SORT(3)
      => target list: default.nation.n_regionkey (INT4), 
default.region.r_regionkey (INT4), default.region.r_regionkey (INT4) + 
default.nation.n_regionkey (INT4) as plus
      => out schema: {(3) default.nation.n_regionkey (INT4), 
default.region.r_regionkey (INT4), plus (INT4)}
      => in schema: {(2) default.nation.n_regionkey (INT4), 
default.region.r_regionkey (INT4)}
-      SCAN(1) on default.nation
-        => target list: default.nation.n_regionkey (INT4)
-        => out schema: {(1) default.nation.n_regionkey (INT4)}
-        => in schema: {(4) default.nation.n_comment (TEXT), 
default.nation.n_name (TEXT), default.nation.n_nationkey (INT4), 
default.nation.n_regionkey (INT4)}
       SCAN(0) on default.region
         => target list: default.region.r_regionkey (INT4)
         => out schema: {(1) default.region.r_regionkey (INT4)}
         => in schema: {(3) default.region.r_comment (TEXT), 
default.region.r_name (TEXT), default.region.r_regionkey (INT4)}
+      SCAN(1) on default.nation
+        => target list: default.nation.n_regionkey (INT4)
+        => out schema: {(1) default.nation.n_regionkey (INT4)}
+        => in schema: {(4) default.nation.n_comment (TEXT), 
default.nation.n_name (TEXT), default.nation.n_nationkey (INT4), 
default.nation.n_regionkey (INT4)}
 explain
 -------------------------------
 -------------------------------------------------------------------------------
@@ -40,32 +40,32 @@ Block Id: eb_0000000000000_0000_000001 [LEAF]
 =======================================================
 
 [Outgoing]
-[q_0000000000000_0000] 1 => 3 (type=HASH_SHUFFLE, 
key=default.region.r_regionkey (INT4), num=32)
+[q_0000000000000_0000] 1 => 3 (type=HASH_SHUFFLE, 
key=default.nation.n_regionkey (INT4), num=32)
 
-SCAN(0) on default.region
-  => target list: default.region.r_regionkey (INT4)
-  => out schema: {(1) default.region.r_regionkey (INT4)}
-  => in schema: {(3) default.region.r_comment (TEXT), default.region.r_name 
(TEXT), default.region.r_regionkey (INT4)}
+SCAN(1) on default.nation
+  => target list: default.nation.n_regionkey (INT4)
+  => out schema: {(1) default.nation.n_regionkey (INT4)}
+  => in schema: {(4) default.nation.n_comment (TEXT), default.nation.n_name 
(TEXT), default.nation.n_nationkey (INT4), default.nation.n_regionkey (INT4)}
 
 =======================================================
 Block Id: eb_0000000000000_0000_000002 [LEAF]
 =======================================================
 
 [Outgoing]
-[q_0000000000000_0000] 2 => 3 (type=HASH_SHUFFLE, 
key=default.nation.n_regionkey (INT4), num=32)
+[q_0000000000000_0000] 2 => 3 (type=HASH_SHUFFLE, 
key=default.region.r_regionkey (INT4), num=32)
 
-SCAN(1) on default.nation
-  => target list: default.nation.n_regionkey (INT4)
-  => out schema: {(1) default.nation.n_regionkey (INT4)}
-  => in schema: {(4) default.nation.n_comment (TEXT), default.nation.n_name 
(TEXT), default.nation.n_nationkey (INT4), default.nation.n_regionkey (INT4)}
+SCAN(0) on default.region
+  => target list: default.region.r_regionkey (INT4)
+  => out schema: {(1) default.region.r_regionkey (INT4)}
+  => in schema: {(3) default.region.r_comment (TEXT), default.region.r_name 
(TEXT), default.region.r_regionkey (INT4)}
 
 =======================================================
 Block Id: eb_0000000000000_0000_000003 [INTERMEDIATE]
 =======================================================
 
 [Incoming]
-[q_0000000000000_0000] 1 => 3 (type=HASH_SHUFFLE, 
key=default.region.r_regionkey (INT4), num=32)
-[q_0000000000000_0000] 2 => 3 (type=HASH_SHUFFLE, 
key=default.nation.n_regionkey (INT4), num=32)
+[q_0000000000000_0000] 1 => 3 (type=HASH_SHUFFLE, 
key=default.nation.n_regionkey (INT4), num=32)
+[q_0000000000000_0000] 2 => 3 (type=HASH_SHUFFLE, 
key=default.region.r_regionkey (INT4), num=32)
 
 [Outgoing]
 [q_0000000000000_0000] 3 => 4 (type=RANGE_SHUFFLE, 
key=default.nation.n_regionkey (INT4), default.region.r_regionkey (INT4), 
num=32)
@@ -78,11 +78,11 @@ SORT(11)
      => out schema: {(3) default.nation.n_regionkey (INT4), 
default.region.r_regionkey (INT4), plus (INT4)}
      => in schema: {(2) default.nation.n_regionkey (INT4), 
default.region.r_regionkey (INT4)}
       SCAN(10) on eb_0000000000000_0000_000002
-        => out schema: {(1) default.nation.n_regionkey (INT4)}
-        => in schema: {(1) default.nation.n_regionkey (INT4)}
-      SCAN(9) on eb_0000000000000_0000_000001
         => out schema: {(1) default.region.r_regionkey (INT4)}
         => in schema: {(1) default.region.r_regionkey (INT4)}
+      SCAN(9) on eb_0000000000000_0000_000001
+        => out schema: {(1) default.nation.n_regionkey (INT4)}
+        => in schema: {(1) default.nation.n_regionkey (INT4)}
 
 =======================================================
 Block Id: eb_0000000000000_0000_000004 [ROOT]

http://git-wip-us.apache.org/repos/asf/tajo/blob/bedce3aa/tajo-core/src/test/resources/results/TestInnerJoinQuery/testJoinOnMultipleDatabases.Hash.plan
----------------------------------------------------------------------
diff --git 
a/tajo-core/src/test/resources/results/TestInnerJoinQuery/testJoinOnMultipleDatabases.Hash.plan
 
b/tajo-core/src/test/resources/results/TestInnerJoinQuery/testJoinOnMultipleDatabases.Hash.plan
index f3b0e9d..c982ee3 100644
--- 
a/tajo-core/src/test/resources/results/TestInnerJoinQuery/testJoinOnMultipleDatabases.Hash.plan
+++ 
b/tajo-core/src/test/resources/results/TestInnerJoinQuery/testJoinOnMultipleDatabases.Hash.plan
@@ -3,45 +3,45 @@ explain
 SORT(6)
   => 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)
    JOIN(16)(INNER)
-     => Join Cond: joins.supplier_.s_suppkey (INT4) = 
default.partsupp.ps_suppkey (INT4)
+     => Join Cond: joins.supplier_.s_nationkey (INT4) = 
default.nation.n_nationkey (INT4)
      => target list: default.nation.n_name (TEXT), joins.part_.p_mfgr (TEXT), 
joins.part_.p_partkey (INT4), joins.supplier_.s_acctbal (FLOAT8), 
joins.supplier_.s_address (TEXT), joins.supplier_.s_comment (TEXT), 
joins.supplier_.s_name (TEXT), joins.supplier_.s_phone (TEXT)
      => out schema: {(8) default.nation.n_name (TEXT), joins.part_.p_mfgr 
(TEXT), joins.part_.p_partkey (INT4), joins.supplier_.s_acctbal (FLOAT8), 
joins.supplier_.s_address (TEXT), joins.supplier_.s_comment (TEXT), 
joins.supplier_.s_name (TEXT), joins.supplier_.s_phone (TEXT)}
-     => in schema: {(10) default.nation.n_name (TEXT), 
default.partsupp.ps_suppkey (INT4), joins.part_.p_mfgr (TEXT), 
joins.part_.p_partkey (INT4), joins.supplier_.s_acctbal (FLOAT8), 
joins.supplier_.s_address (TEXT), joins.supplier_.s_comment (TEXT), 
joins.supplier_.s_name (TEXT), joins.supplier_.s_phone (TEXT), 
joins.supplier_.s_suppkey (INT4)}
+     => in schema: {(10) default.nation.n_name (TEXT), 
default.nation.n_nationkey (INT4), joins.part_.p_mfgr (TEXT), 
joins.part_.p_partkey (INT4), joins.supplier_.s_acctbal (FLOAT8), 
joins.supplier_.s_address (TEXT), joins.supplier_.s_comment (TEXT), 
joins.supplier_.s_name (TEXT), joins.supplier_.s_nationkey (INT4), 
joins.supplier_.s_phone (TEXT)}
       JOIN(15)(INNER)
-        => Join Cond: joins.part_.p_partkey (INT4) = 
default.partsupp.ps_partkey (INT4)
-        => target list: default.partsupp.ps_suppkey (INT4), joins.part_.p_mfgr 
(TEXT), joins.part_.p_partkey (INT4)
-        => out schema: {(3) default.partsupp.ps_suppkey (INT4), 
joins.part_.p_mfgr (TEXT), joins.part_.p_partkey (INT4)}
-        => in schema: {(4) default.partsupp.ps_partkey (INT4), 
default.partsupp.ps_suppkey (INT4), joins.part_.p_mfgr (TEXT), 
joins.part_.p_partkey (INT4)}
-         SCAN(2) on default.partsupp
-           => target list: default.partsupp.ps_partkey (INT4), 
default.partsupp.ps_suppkey (INT4)
-           => out schema: {(2) default.partsupp.ps_partkey (INT4), 
default.partsupp.ps_suppkey (INT4)}
-           => in schema: {(5) default.partsupp.ps_availqty (INT4), 
default.partsupp.ps_comment (TEXT), default.partsupp.ps_partkey (INT4), 
default.partsupp.ps_suppkey (INT4), default.partsupp.ps_supplycost (FLOAT8)}
-         SCAN(0) on joins.part_
-           => target list: joins.part_.p_mfgr (TEXT), joins.part_.p_partkey 
(INT4)
-           => out schema: {(2) joins.part_.p_mfgr (TEXT), 
joins.part_.p_partkey (INT4)}
-           => in schema: {(9) joins.part_.p_brand (TEXT), 
joins.part_.p_comment (TEXT), joins.part_.p_container (TEXT), 
joins.part_.p_mfgr (TEXT), joins.part_.p_name (TEXT), joins.part_.p_partkey 
(INT4), joins.part_.p_retailprice (FLOAT8), joins.part_.p_size (INT4), 
joins.part_.p_type (TEXT)}
-      JOIN(14)(INNER)
         => Join Cond: default.nation.n_regionkey (INT4) = 
default.region.r_regionkey (INT4)
-        => target list: default.nation.n_name (TEXT), 
joins.supplier_.s_acctbal (FLOAT8), joins.supplier_.s_address (TEXT), 
joins.supplier_.s_comment (TEXT), joins.supplier_.s_name (TEXT), 
joins.supplier_.s_phone (TEXT), joins.supplier_.s_suppkey (INT4)
-        => out schema: {(7) default.nation.n_name (TEXT), 
joins.supplier_.s_acctbal (FLOAT8), joins.supplier_.s_address (TEXT), 
joins.supplier_.s_comment (TEXT), joins.supplier_.s_name (TEXT), 
joins.supplier_.s_phone (TEXT), joins.supplier_.s_suppkey (INT4)}
-        => in schema: {(9) default.nation.n_name (TEXT), 
default.nation.n_regionkey (INT4), default.region.r_regionkey (INT4), 
joins.supplier_.s_acctbal (FLOAT8), joins.supplier_.s_address (TEXT), 
joins.supplier_.s_comment (TEXT), joins.supplier_.s_name (TEXT), 
joins.supplier_.s_phone (TEXT), joins.supplier_.s_suppkey (INT4)}
+        => target list: default.nation.n_name (TEXT), 
default.nation.n_nationkey (INT4)
+        => out schema: {(2) default.nation.n_name (TEXT), 
default.nation.n_nationkey (INT4)}
+        => in schema: {(4) default.nation.n_name (TEXT), 
default.nation.n_nationkey (INT4), default.nation.n_regionkey (INT4), 
default.region.r_regionkey (INT4)}
          SCAN(4) on default.region
            => target list: default.region.r_regionkey (INT4)
            => out schema: {(1) default.region.r_regionkey (INT4)}
            => in schema: {(3) default.region.r_comment (TEXT), 
default.region.r_name (TEXT), default.region.r_regionkey (INT4)}
+         SCAN(3) on default.nation
+           => target list: default.nation.n_name (TEXT), 
default.nation.n_nationkey (INT4), default.nation.n_regionkey (INT4)
+           => out schema: {(3) default.nation.n_name (TEXT), 
default.nation.n_nationkey (INT4), default.nation.n_regionkey (INT4)}
+           => in schema: {(4) default.nation.n_comment (TEXT), 
default.nation.n_name (TEXT), default.nation.n_nationkey (INT4), 
default.nation.n_regionkey (INT4)}
+      JOIN(14)(INNER)
+        => Join Cond: joins.part_.p_partkey (INT4) = 
default.partsupp.ps_partkey (INT4)
+        => target list: joins.part_.p_mfgr (TEXT), joins.part_.p_partkey 
(INT4), joins.supplier_.s_acctbal (FLOAT8), joins.supplier_.s_address (TEXT), 
joins.supplier_.s_comment (TEXT), joins.supplier_.s_name (TEXT), 
joins.supplier_.s_nationkey (INT4), joins.supplier_.s_phone (TEXT)
+        => out schema: {(8) joins.part_.p_mfgr (TEXT), joins.part_.p_partkey 
(INT4), joins.supplier_.s_acctbal (FLOAT8), joins.supplier_.s_address (TEXT), 
joins.supplier_.s_comment (TEXT), joins.supplier_.s_name (TEXT), 
joins.supplier_.s_nationkey (INT4), joins.supplier_.s_phone (TEXT)}
+        => in schema: {(9) default.partsupp.ps_partkey (INT4), 
joins.part_.p_mfgr (TEXT), joins.part_.p_partkey (INT4), 
joins.supplier_.s_acctbal (FLOAT8), joins.supplier_.s_address (TEXT), 
joins.supplier_.s_comment (TEXT), joins.supplier_.s_name (TEXT), 
joins.supplier_.s_nationkey (INT4), joins.supplier_.s_phone (TEXT)}
+         SCAN(0) on joins.part_
+           => target list: joins.part_.p_mfgr (TEXT), joins.part_.p_partkey 
(INT4)
+           => out schema: {(2) joins.part_.p_mfgr (TEXT), 
joins.part_.p_partkey (INT4)}
+           => in schema: {(9) joins.part_.p_brand (TEXT), 
joins.part_.p_comment (TEXT), joins.part_.p_container (TEXT), 
joins.part_.p_mfgr (TEXT), joins.part_.p_name (TEXT), joins.part_.p_partkey 
(INT4), joins.part_.p_retailprice (FLOAT8), joins.part_.p_size (INT4), 
joins.part_.p_type (TEXT)}
          JOIN(13)(INNER)
-           => Join Cond: joins.supplier_.s_nationkey (INT4) = 
default.nation.n_nationkey (INT4)
-           => target list: default.nation.n_name (TEXT), 
default.nation.n_regionkey (INT4), joins.supplier_.s_acctbal (FLOAT8), 
joins.supplier_.s_address (TEXT), joins.supplier_.s_comment (TEXT), 
joins.supplier_.s_name (TEXT), joins.supplier_.s_phone (TEXT), 
joins.supplier_.s_suppkey (INT4)
-           => out schema: {(8) default.nation.n_name (TEXT), 
default.nation.n_regionkey (INT4), joins.supplier_.s_acctbal (FLOAT8), 
joins.supplier_.s_address (TEXT), joins.supplier_.s_comment (TEXT), 
joins.supplier_.s_name (TEXT), joins.supplier_.s_phone (TEXT), 
joins.supplier_.s_suppkey (INT4)}
-           => in schema: {(10) default.nation.n_name (TEXT), 
default.nation.n_nationkey (INT4), default.nation.n_regionkey (INT4), 
joins.supplier_.s_acctbal (FLOAT8), joins.supplier_.s_address (TEXT), 
joins.supplier_.s_comment (TEXT), joins.supplier_.s_name (TEXT), 
joins.supplier_.s_nationkey (INT4), joins.supplier_.s_phone (TEXT), 
joins.supplier_.s_suppkey (INT4)}
-            SCAN(3) on default.nation
-              => target list: default.nation.n_name (TEXT), 
default.nation.n_nationkey (INT4), default.nation.n_regionkey (INT4)
-              => out schema: {(3) default.nation.n_name (TEXT), 
default.nation.n_nationkey (INT4), default.nation.n_regionkey (INT4)}
-              => in schema: {(4) default.nation.n_comment (TEXT), 
default.nation.n_name (TEXT), default.nation.n_nationkey (INT4), 
default.nation.n_regionkey (INT4)}
+           => Join Cond: joins.supplier_.s_suppkey (INT4) = 
default.partsupp.ps_suppkey (INT4)
+           => target list: default.partsupp.ps_partkey (INT4), 
joins.supplier_.s_acctbal (FLOAT8), joins.supplier_.s_address (TEXT), 
joins.supplier_.s_comment (TEXT), joins.supplier_.s_name (TEXT), 
joins.supplier_.s_nationkey (INT4), joins.supplier_.s_phone (TEXT)
+           => out schema: {(7) default.partsupp.ps_partkey (INT4), 
joins.supplier_.s_acctbal (FLOAT8), joins.supplier_.s_address (TEXT), 
joins.supplier_.s_comment (TEXT), joins.supplier_.s_name (TEXT), 
joins.supplier_.s_nationkey (INT4), joins.supplier_.s_phone (TEXT)}
+           => in schema: {(9) default.partsupp.ps_partkey (INT4), 
default.partsupp.ps_suppkey (INT4), joins.supplier_.s_acctbal (FLOAT8), 
joins.supplier_.s_address (TEXT), joins.supplier_.s_comment (TEXT), 
joins.supplier_.s_name (TEXT), joins.supplier_.s_nationkey (INT4), 
joins.supplier_.s_phone (TEXT), joins.supplier_.s_suppkey (INT4)}
             SCAN(1) on joins.supplier_
               => target list: joins.supplier_.s_acctbal (FLOAT8), 
joins.supplier_.s_address (TEXT), joins.supplier_.s_comment (TEXT), 
joins.supplier_.s_name (TEXT), joins.supplier_.s_nationkey (INT4), 
joins.supplier_.s_phone (TEXT), joins.supplier_.s_suppkey (INT4)
               => out schema: {(7) joins.supplier_.s_acctbal (FLOAT8), 
joins.supplier_.s_address (TEXT), joins.supplier_.s_comment (TEXT), 
joins.supplier_.s_name (TEXT), joins.supplier_.s_nationkey (INT4), 
joins.supplier_.s_phone (TEXT), joins.supplier_.s_suppkey (INT4)}
               => in schema: {(7) joins.supplier_.s_acctbal (FLOAT8), 
joins.supplier_.s_address (TEXT), joins.supplier_.s_comment (TEXT), 
joins.supplier_.s_name (TEXT), joins.supplier_.s_nationkey (INT4), 
joins.supplier_.s_phone (TEXT), joins.supplier_.s_suppkey (INT4)}
+            SCAN(2) on default.partsupp
+              => target list: default.partsupp.ps_partkey (INT4), 
default.partsupp.ps_suppkey (INT4)
+              => out schema: {(2) default.partsupp.ps_partkey (INT4), 
default.partsupp.ps_suppkey (INT4)}
+              => in schema: {(5) default.partsupp.ps_availqty (INT4), 
default.partsupp.ps_comment (TEXT), default.partsupp.ps_partkey (INT4), 
default.partsupp.ps_suppkey (INT4), default.partsupp.ps_supplycost (FLOAT8)}
 explain
 -------------------------------
 -------------------------------------------------------------------------------
@@ -67,52 +67,52 @@ Block Id: eb_0000000000000_0000_000009 [LEAF]
 
 [Enforcers]
  0: type=Broadcast, tables=joins.supplier_
- 1: type=Broadcast, tables=default.region
- 2: type=Broadcast, tables=joins.part_
- 3: type=Broadcast, tables=default.partsupp
+ 1: type=Broadcast, tables=joins.part_
+ 2: type=Broadcast, tables=default.partsupp
+ 3: type=Broadcast, tables=default.region
 
 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)
    JOIN(16)(INNER)
-     => Join Cond: joins.supplier_.s_suppkey (INT4) = 
default.partsupp.ps_suppkey (INT4)
+     => Join Cond: joins.supplier_.s_nationkey (INT4) = 
default.nation.n_nationkey (INT4)
      => target list: default.nation.n_name (TEXT), joins.part_.p_mfgr (TEXT), 
joins.part_.p_partkey (INT4), joins.supplier_.s_acctbal (FLOAT8), 
joins.supplier_.s_address (TEXT), joins.supplier_.s_comment (TEXT), 
joins.supplier_.s_name (TEXT), joins.supplier_.s_phone (TEXT)
      => out schema: {(8) default.nation.n_name (TEXT), joins.part_.p_mfgr 
(TEXT), joins.part_.p_partkey (INT4), joins.supplier_.s_acctbal (FLOAT8), 
joins.supplier_.s_address (TEXT), joins.supplier_.s_comment (TEXT), 
joins.supplier_.s_name (TEXT), joins.supplier_.s_phone (TEXT)}
-     => in schema: {(10) default.nation.n_name (TEXT), 
default.partsupp.ps_suppkey (INT4), joins.part_.p_mfgr (TEXT), 
joins.part_.p_partkey (INT4), joins.supplier_.s_acctbal (FLOAT8), 
joins.supplier_.s_address (TEXT), joins.supplier_.s_comment (TEXT), 
joins.supplier_.s_name (TEXT), joins.supplier_.s_phone (TEXT), 
joins.supplier_.s_suppkey (INT4)}
+     => in schema: {(10) default.nation.n_name (TEXT), 
default.nation.n_nationkey (INT4), joins.part_.p_mfgr (TEXT), 
joins.part_.p_partkey (INT4), joins.supplier_.s_acctbal (FLOAT8), 
joins.supplier_.s_address (TEXT), joins.supplier_.s_comment (TEXT), 
joins.supplier_.s_name (TEXT), joins.supplier_.s_nationkey (INT4), 
joins.supplier_.s_phone (TEXT)}
       JOIN(15)(INNER)
-        => Join Cond: joins.part_.p_partkey (INT4) = 
default.partsupp.ps_partkey (INT4)
-        => target list: default.partsupp.ps_suppkey (INT4), joins.part_.p_mfgr 
(TEXT), joins.part_.p_partkey (INT4)
-        => out schema: {(3) default.partsupp.ps_suppkey (INT4), 
joins.part_.p_mfgr (TEXT), joins.part_.p_partkey (INT4)}
-        => in schema: {(4) default.partsupp.ps_partkey (INT4), 
default.partsupp.ps_suppkey (INT4), joins.part_.p_mfgr (TEXT), 
joins.part_.p_partkey (INT4)}
-         SCAN(2) on default.partsupp
-           => target list: default.partsupp.ps_partkey (INT4), 
default.partsupp.ps_suppkey (INT4)
-           => out schema: {(2) default.partsupp.ps_partkey (INT4), 
default.partsupp.ps_suppkey (INT4)}
-           => in schema: {(5) default.partsupp.ps_availqty (INT4), 
default.partsupp.ps_comment (TEXT), default.partsupp.ps_partkey (INT4), 
default.partsupp.ps_suppkey (INT4), default.partsupp.ps_supplycost (FLOAT8)}
-         SCAN(0) on joins.part_
-           => target list: joins.part_.p_mfgr (TEXT), joins.part_.p_partkey 
(INT4)
-           => out schema: {(2) joins.part_.p_mfgr (TEXT), 
joins.part_.p_partkey (INT4)}
-           => in schema: {(9) joins.part_.p_brand (TEXT), 
joins.part_.p_comment (TEXT), joins.part_.p_container (TEXT), 
joins.part_.p_mfgr (TEXT), joins.part_.p_name (TEXT), joins.part_.p_partkey 
(INT4), joins.part_.p_retailprice (FLOAT8), joins.part_.p_size (INT4), 
joins.part_.p_type (TEXT)}
-      JOIN(14)(INNER)
         => Join Cond: default.nation.n_regionkey (INT4) = 
default.region.r_regionkey (INT4)
-        => target list: default.nation.n_name (TEXT), 
joins.supplier_.s_acctbal (FLOAT8), joins.supplier_.s_address (TEXT), 
joins.supplier_.s_comment (TEXT), joins.supplier_.s_name (TEXT), 
joins.supplier_.s_phone (TEXT), joins.supplier_.s_suppkey (INT4)
-        => out schema: {(7) default.nation.n_name (TEXT), 
joins.supplier_.s_acctbal (FLOAT8), joins.supplier_.s_address (TEXT), 
joins.supplier_.s_comment (TEXT), joins.supplier_.s_name (TEXT), 
joins.supplier_.s_phone (TEXT), joins.supplier_.s_suppkey (INT4)}
-        => in schema: {(9) default.nation.n_name (TEXT), 
default.nation.n_regionkey (INT4), default.region.r_regionkey (INT4), 
joins.supplier_.s_acctbal (FLOAT8), joins.supplier_.s_address (TEXT), 
joins.supplier_.s_comment (TEXT), joins.supplier_.s_name (TEXT), 
joins.supplier_.s_phone (TEXT), joins.supplier_.s_suppkey (INT4)}
+        => target list: default.nation.n_name (TEXT), 
default.nation.n_nationkey (INT4)
+        => out schema: {(2) default.nation.n_name (TEXT), 
default.nation.n_nationkey (INT4)}
+        => in schema: {(4) default.nation.n_name (TEXT), 
default.nation.n_nationkey (INT4), default.nation.n_regionkey (INT4), 
default.region.r_regionkey (INT4)}
          SCAN(4) on default.region
            => target list: default.region.r_regionkey (INT4)
            => out schema: {(1) default.region.r_regionkey (INT4)}
            => in schema: {(3) default.region.r_comment (TEXT), 
default.region.r_name (TEXT), default.region.r_regionkey (INT4)}
+         SCAN(3) on default.nation
+           => target list: default.nation.n_name (TEXT), 
default.nation.n_nationkey (INT4), default.nation.n_regionkey (INT4)
+           => out schema: {(3) default.nation.n_name (TEXT), 
default.nation.n_nationkey (INT4), default.nation.n_regionkey (INT4)}
+           => in schema: {(4) default.nation.n_comment (TEXT), 
default.nation.n_name (TEXT), default.nation.n_nationkey (INT4), 
default.nation.n_regionkey (INT4)}
+      JOIN(14)(INNER)
+        => Join Cond: joins.part_.p_partkey (INT4) = 
default.partsupp.ps_partkey (INT4)
+        => target list: joins.part_.p_mfgr (TEXT), joins.part_.p_partkey 
(INT4), joins.supplier_.s_acctbal (FLOAT8), joins.supplier_.s_address (TEXT), 
joins.supplier_.s_comment (TEXT), joins.supplier_.s_name (TEXT), 
joins.supplier_.s_nationkey (INT4), joins.supplier_.s_phone (TEXT)
+        => out schema: {(8) joins.part_.p_mfgr (TEXT), joins.part_.p_partkey 
(INT4), joins.supplier_.s_acctbal (FLOAT8), joins.supplier_.s_address (TEXT), 
joins.supplier_.s_comment (TEXT), joins.supplier_.s_name (TEXT), 
joins.supplier_.s_nationkey (INT4), joins.supplier_.s_phone (TEXT)}
+        => in schema: {(9) default.partsupp.ps_partkey (INT4), 
joins.part_.p_mfgr (TEXT), joins.part_.p_partkey (INT4), 
joins.supplier_.s_acctbal (FLOAT8), joins.supplier_.s_address (TEXT), 
joins.supplier_.s_comment (TEXT), joins.supplier_.s_name (TEXT), 
joins.supplier_.s_nationkey (INT4), joins.supplier_.s_phone (TEXT)}
+         SCAN(0) on joins.part_
+           => target list: joins.part_.p_mfgr (TEXT), joins.part_.p_partkey 
(INT4)
+           => out schema: {(2) joins.part_.p_mfgr (TEXT), 
joins.part_.p_partkey (INT4)}
+           => in schema: {(9) joins.part_.p_brand (TEXT), 
joins.part_.p_comment (TEXT), joins.part_.p_container (TEXT), 
joins.part_.p_mfgr (TEXT), joins.part_.p_name (TEXT), joins.part_.p_partkey 
(INT4), joins.part_.p_retailprice (FLOAT8), joins.part_.p_size (INT4), 
joins.part_.p_type (TEXT)}
          JOIN(13)(INNER)
-           => Join Cond: joins.supplier_.s_nationkey (INT4) = 
default.nation.n_nationkey (INT4)
-           => target list: default.nation.n_name (TEXT), 
default.nation.n_regionkey (INT4), joins.supplier_.s_acctbal (FLOAT8), 
joins.supplier_.s_address (TEXT), joins.supplier_.s_comment (TEXT), 
joins.supplier_.s_name (TEXT), joins.supplier_.s_phone (TEXT), 
joins.supplier_.s_suppkey (INT4)
-           => out schema: {(8) default.nation.n_name (TEXT), 
default.nation.n_regionkey (INT4), joins.supplier_.s_acctbal (FLOAT8), 
joins.supplier_.s_address (TEXT), joins.supplier_.s_comment (TEXT), 
joins.supplier_.s_name (TEXT), joins.supplier_.s_phone (TEXT), 
joins.supplier_.s_suppkey (INT4)}
-           => in schema: {(10) default.nation.n_name (TEXT), 
default.nation.n_nationkey (INT4), default.nation.n_regionkey (INT4), 
joins.supplier_.s_acctbal (FLOAT8), joins.supplier_.s_address (TEXT), 
joins.supplier_.s_comment (TEXT), joins.supplier_.s_name (TEXT), 
joins.supplier_.s_nationkey (INT4), joins.supplier_.s_phone (TEXT), 
joins.supplier_.s_suppkey (INT4)}
-            SCAN(3) on default.nation
-              => target list: default.nation.n_name (TEXT), 
default.nation.n_nationkey (INT4), default.nation.n_regionkey (INT4)
-              => out schema: {(3) default.nation.n_name (TEXT), 
default.nation.n_nationkey (INT4), default.nation.n_regionkey (INT4)}
-              => in schema: {(4) default.nation.n_comment (TEXT), 
default.nation.n_name (TEXT), default.nation.n_nationkey (INT4), 
default.nation.n_regionkey (INT4)}
+           => Join Cond: joins.supplier_.s_suppkey (INT4) = 
default.partsupp.ps_suppkey (INT4)
+           => target list: default.partsupp.ps_partkey (INT4), 
joins.supplier_.s_acctbal (FLOAT8), joins.supplier_.s_address (TEXT), 
joins.supplier_.s_comment (TEXT), joins.supplier_.s_name (TEXT), 
joins.supplier_.s_nationkey (INT4), joins.supplier_.s_phone (TEXT)
+           => out schema: {(7) default.partsupp.ps_partkey (INT4), 
joins.supplier_.s_acctbal (FLOAT8), joins.supplier_.s_address (TEXT), 
joins.supplier_.s_comment (TEXT), joins.supplier_.s_name (TEXT), 
joins.supplier_.s_nationkey (INT4), joins.supplier_.s_phone (TEXT)}
+           => in schema: {(9) default.partsupp.ps_partkey (INT4), 
default.partsupp.ps_suppkey (INT4), joins.supplier_.s_acctbal (FLOAT8), 
joins.supplier_.s_address (TEXT), joins.supplier_.s_comment (TEXT), 
joins.supplier_.s_name (TEXT), joins.supplier_.s_nationkey (INT4), 
joins.supplier_.s_phone (TEXT), joins.supplier_.s_suppkey (INT4)}
             SCAN(1) on joins.supplier_
               => target list: joins.supplier_.s_acctbal (FLOAT8), 
joins.supplier_.s_address (TEXT), joins.supplier_.s_comment (TEXT), 
joins.supplier_.s_name (TEXT), joins.supplier_.s_nationkey (INT4), 
joins.supplier_.s_phone (TEXT), joins.supplier_.s_suppkey (INT4)
               => out schema: {(7) joins.supplier_.s_acctbal (FLOAT8), 
joins.supplier_.s_address (TEXT), joins.supplier_.s_comment (TEXT), 
joins.supplier_.s_name (TEXT), joins.supplier_.s_nationkey (INT4), 
joins.supplier_.s_phone (TEXT), joins.supplier_.s_suppkey (INT4)}
               => in schema: {(7) joins.supplier_.s_acctbal (FLOAT8), 
joins.supplier_.s_address (TEXT), joins.supplier_.s_comment (TEXT), 
joins.supplier_.s_name (TEXT), joins.supplier_.s_nationkey (INT4), 
joins.supplier_.s_phone (TEXT), joins.supplier_.s_suppkey (INT4)}
+            SCAN(2) on default.partsupp
+              => target list: default.partsupp.ps_partkey (INT4), 
default.partsupp.ps_suppkey (INT4)
+              => out schema: {(2) default.partsupp.ps_partkey (INT4), 
default.partsupp.ps_suppkey (INT4)}
+              => in schema: {(5) default.partsupp.ps_availqty (INT4), 
default.partsupp.ps_comment (TEXT), default.partsupp.ps_partkey (INT4), 
default.partsupp.ps_suppkey (INT4), default.partsupp.ps_supplycost (FLOAT8)}
 
 =======================================================
 Block Id: eb_0000000000000_0000_000010 [ROOT]

http://git-wip-us.apache.org/repos/asf/tajo/blob/bedce3aa/tajo-core/src/test/resources/results/TestInnerJoinQuery/testJoinOnMultipleDatabases.Hash_NoBroadcast.plan
----------------------------------------------------------------------
diff --git 
a/tajo-core/src/test/resources/results/TestInnerJoinQuery/testJoinOnMultipleDatabases.Hash_NoBroadcast.plan
 
b/tajo-core/src/test/resources/results/TestInnerJoinQuery/testJoinOnMultipleDatabases.Hash_NoBroadcast.plan
index 59e9b93..19750a2 100644
--- 
a/tajo-core/src/test/resources/results/TestInnerJoinQuery/testJoinOnMultipleDatabases.Hash_NoBroadcast.plan
+++ 
b/tajo-core/src/test/resources/results/TestInnerJoinQuery/testJoinOnMultipleDatabases.Hash_NoBroadcast.plan
@@ -3,45 +3,45 @@ explain
 SORT(6)
   => 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)
    JOIN(16)(INNER)
-     => Join Cond: joins.supplier_.s_suppkey (INT4) = 
default.partsupp.ps_suppkey (INT4)
+     => Join Cond: joins.supplier_.s_nationkey (INT4) = 
default.nation.n_nationkey (INT4)
      => target list: default.nation.n_name (TEXT), joins.part_.p_mfgr (TEXT), 
joins.part_.p_partkey (INT4), joins.supplier_.s_acctbal (FLOAT8), 
joins.supplier_.s_address (TEXT), joins.supplier_.s_comment (TEXT), 
joins.supplier_.s_name (TEXT), joins.supplier_.s_phone (TEXT)
      => out schema: {(8) default.nation.n_name (TEXT), joins.part_.p_mfgr 
(TEXT), joins.part_.p_partkey (INT4), joins.supplier_.s_acctbal (FLOAT8), 
joins.supplier_.s_address (TEXT), joins.supplier_.s_comment (TEXT), 
joins.supplier_.s_name (TEXT), joins.supplier_.s_phone (TEXT)}
-     => in schema: {(10) default.nation.n_name (TEXT), 
default.partsupp.ps_suppkey (INT4), joins.part_.p_mfgr (TEXT), 
joins.part_.p_partkey (INT4), joins.supplier_.s_acctbal (FLOAT8), 
joins.supplier_.s_address (TEXT), joins.supplier_.s_comment (TEXT), 
joins.supplier_.s_name (TEXT), joins.supplier_.s_phone (TEXT), 
joins.supplier_.s_suppkey (INT4)}
+     => in schema: {(10) default.nation.n_name (TEXT), 
default.nation.n_nationkey (INT4), joins.part_.p_mfgr (TEXT), 
joins.part_.p_partkey (INT4), joins.supplier_.s_acctbal (FLOAT8), 
joins.supplier_.s_address (TEXT), joins.supplier_.s_comment (TEXT), 
joins.supplier_.s_name (TEXT), joins.supplier_.s_nationkey (INT4), 
joins.supplier_.s_phone (TEXT)}
       JOIN(15)(INNER)
-        => Join Cond: joins.part_.p_partkey (INT4) = 
default.partsupp.ps_partkey (INT4)
-        => target list: default.partsupp.ps_suppkey (INT4), joins.part_.p_mfgr 
(TEXT), joins.part_.p_partkey (INT4)
-        => out schema: {(3) default.partsupp.ps_suppkey (INT4), 
joins.part_.p_mfgr (TEXT), joins.part_.p_partkey (INT4)}
-        => in schema: {(4) default.partsupp.ps_partkey (INT4), 
default.partsupp.ps_suppkey (INT4), joins.part_.p_mfgr (TEXT), 
joins.part_.p_partkey (INT4)}
-         SCAN(2) on default.partsupp
-           => target list: default.partsupp.ps_partkey (INT4), 
default.partsupp.ps_suppkey (INT4)
-           => out schema: {(2) default.partsupp.ps_partkey (INT4), 
default.partsupp.ps_suppkey (INT4)}
-           => in schema: {(5) default.partsupp.ps_availqty (INT4), 
default.partsupp.ps_comment (TEXT), default.partsupp.ps_partkey (INT4), 
default.partsupp.ps_suppkey (INT4), default.partsupp.ps_supplycost (FLOAT8)}
-         SCAN(0) on joins.part_
-           => target list: joins.part_.p_mfgr (TEXT), joins.part_.p_partkey 
(INT4)
-           => out schema: {(2) joins.part_.p_mfgr (TEXT), 
joins.part_.p_partkey (INT4)}
-           => in schema: {(9) joins.part_.p_brand (TEXT), 
joins.part_.p_comment (TEXT), joins.part_.p_container (TEXT), 
joins.part_.p_mfgr (TEXT), joins.part_.p_name (TEXT), joins.part_.p_partkey 
(INT4), joins.part_.p_retailprice (FLOAT8), joins.part_.p_size (INT4), 
joins.part_.p_type (TEXT)}
-      JOIN(14)(INNER)
         => Join Cond: default.nation.n_regionkey (INT4) = 
default.region.r_regionkey (INT4)
-        => target list: default.nation.n_name (TEXT), 
joins.supplier_.s_acctbal (FLOAT8), joins.supplier_.s_address (TEXT), 
joins.supplier_.s_comment (TEXT), joins.supplier_.s_name (TEXT), 
joins.supplier_.s_phone (TEXT), joins.supplier_.s_suppkey (INT4)
-        => out schema: {(7) default.nation.n_name (TEXT), 
joins.supplier_.s_acctbal (FLOAT8), joins.supplier_.s_address (TEXT), 
joins.supplier_.s_comment (TEXT), joins.supplier_.s_name (TEXT), 
joins.supplier_.s_phone (TEXT), joins.supplier_.s_suppkey (INT4)}
-        => in schema: {(9) default.nation.n_name (TEXT), 
default.nation.n_regionkey (INT4), default.region.r_regionkey (INT4), 
joins.supplier_.s_acctbal (FLOAT8), joins.supplier_.s_address (TEXT), 
joins.supplier_.s_comment (TEXT), joins.supplier_.s_name (TEXT), 
joins.supplier_.s_phone (TEXT), joins.supplier_.s_suppkey (INT4)}
+        => target list: default.nation.n_name (TEXT), 
default.nation.n_nationkey (INT4)
+        => out schema: {(2) default.nation.n_name (TEXT), 
default.nation.n_nationkey (INT4)}
+        => in schema: {(4) default.nation.n_name (TEXT), 
default.nation.n_nationkey (INT4), default.nation.n_regionkey (INT4), 
default.region.r_regionkey (INT4)}
          SCAN(4) on default.region
            => target list: default.region.r_regionkey (INT4)
            => out schema: {(1) default.region.r_regionkey (INT4)}
            => in schema: {(3) default.region.r_comment (TEXT), 
default.region.r_name (TEXT), default.region.r_regionkey (INT4)}
+         SCAN(3) on default.nation
+           => target list: default.nation.n_name (TEXT), 
default.nation.n_nationkey (INT4), default.nation.n_regionkey (INT4)
+           => out schema: {(3) default.nation.n_name (TEXT), 
default.nation.n_nationkey (INT4), default.nation.n_regionkey (INT4)}
+           => in schema: {(4) default.nation.n_comment (TEXT), 
default.nation.n_name (TEXT), default.nation.n_nationkey (INT4), 
default.nation.n_regionkey (INT4)}
+      JOIN(14)(INNER)
+        => Join Cond: joins.part_.p_partkey (INT4) = 
default.partsupp.ps_partkey (INT4)
+        => target list: joins.part_.p_mfgr (TEXT), joins.part_.p_partkey 
(INT4), joins.supplier_.s_acctbal (FLOAT8), joins.supplier_.s_address (TEXT), 
joins.supplier_.s_comment (TEXT), joins.supplier_.s_name (TEXT), 
joins.supplier_.s_nationkey (INT4), joins.supplier_.s_phone (TEXT)
+        => out schema: {(8) joins.part_.p_mfgr (TEXT), joins.part_.p_partkey 
(INT4), joins.supplier_.s_acctbal (FLOAT8), joins.supplier_.s_address (TEXT), 
joins.supplier_.s_comment (TEXT), joins.supplier_.s_name (TEXT), 
joins.supplier_.s_nationkey (INT4), joins.supplier_.s_phone (TEXT)}
+        => in schema: {(9) default.partsupp.ps_partkey (INT4), 
joins.part_.p_mfgr (TEXT), joins.part_.p_partkey (INT4), 
joins.supplier_.s_acctbal (FLOAT8), joins.supplier_.s_address (TEXT), 
joins.supplier_.s_comment (TEXT), joins.supplier_.s_name (TEXT), 
joins.supplier_.s_nationkey (INT4), joins.supplier_.s_phone (TEXT)}
+         SCAN(0) on joins.part_
+           => target list: joins.part_.p_mfgr (TEXT), joins.part_.p_partkey 
(INT4)
+           => out schema: {(2) joins.part_.p_mfgr (TEXT), 
joins.part_.p_partkey (INT4)}
+           => in schema: {(9) joins.part_.p_brand (TEXT), 
joins.part_.p_comment (TEXT), joins.part_.p_container (TEXT), 
joins.part_.p_mfgr (TEXT), joins.part_.p_name (TEXT), joins.part_.p_partkey 
(INT4), joins.part_.p_retailprice (FLOAT8), joins.part_.p_size (INT4), 
joins.part_.p_type (TEXT)}
          JOIN(13)(INNER)
-           => Join Cond: joins.supplier_.s_nationkey (INT4) = 
default.nation.n_nationkey (INT4)
-           => target list: default.nation.n_name (TEXT), 
default.nation.n_regionkey (INT4), joins.supplier_.s_acctbal (FLOAT8), 
joins.supplier_.s_address (TEXT), joins.supplier_.s_comment (TEXT), 
joins.supplier_.s_name (TEXT), joins.supplier_.s_phone (TEXT), 
joins.supplier_.s_suppkey (INT4)
-           => out schema: {(8) default.nation.n_name (TEXT), 
default.nation.n_regionkey (INT4), joins.supplier_.s_acctbal (FLOAT8), 
joins.supplier_.s_address (TEXT), joins.supplier_.s_comment (TEXT), 
joins.supplier_.s_name (TEXT), joins.supplier_.s_phone (TEXT), 
joins.supplier_.s_suppkey (INT4)}
-           => in schema: {(10) default.nation.n_name (TEXT), 
default.nation.n_nationkey (INT4), default.nation.n_regionkey (INT4), 
joins.supplier_.s_acctbal (FLOAT8), joins.supplier_.s_address (TEXT), 
joins.supplier_.s_comment (TEXT), joins.supplier_.s_name (TEXT), 
joins.supplier_.s_nationkey (INT4), joins.supplier_.s_phone (TEXT), 
joins.supplier_.s_suppkey (INT4)}
-            SCAN(3) on default.nation
-              => target list: default.nation.n_name (TEXT), 
default.nation.n_nationkey (INT4), default.nation.n_regionkey (INT4)
-              => out schema: {(3) default.nation.n_name (TEXT), 
default.nation.n_nationkey (INT4), default.nation.n_regionkey (INT4)}
-              => in schema: {(4) default.nation.n_comment (TEXT), 
default.nation.n_name (TEXT), default.nation.n_nationkey (INT4), 
default.nation.n_regionkey (INT4)}
+           => Join Cond: joins.supplier_.s_suppkey (INT4) = 
default.partsupp.ps_suppkey (INT4)
+           => target list: default.partsupp.ps_partkey (INT4), 
joins.supplier_.s_acctbal (FLOAT8), joins.supplier_.s_address (TEXT), 
joins.supplier_.s_comment (TEXT), joins.supplier_.s_name (TEXT), 
joins.supplier_.s_nationkey (INT4), joins.supplier_.s_phone (TEXT)
+           => out schema: {(7) default.partsupp.ps_partkey (INT4), 
joins.supplier_.s_acctbal (FLOAT8), joins.supplier_.s_address (TEXT), 
joins.supplier_.s_comment (TEXT), joins.supplier_.s_name (TEXT), 
joins.supplier_.s_nationkey (INT4), joins.supplier_.s_phone (TEXT)}
+           => in schema: {(9) default.partsupp.ps_partkey (INT4), 
default.partsupp.ps_suppkey (INT4), joins.supplier_.s_acctbal (FLOAT8), 
joins.supplier_.s_address (TEXT), joins.supplier_.s_comment (TEXT), 
joins.supplier_.s_name (TEXT), joins.supplier_.s_nationkey (INT4), 
joins.supplier_.s_phone (TEXT), joins.supplier_.s_suppkey (INT4)}
             SCAN(1) on joins.supplier_
               => target list: joins.supplier_.s_acctbal (FLOAT8), 
joins.supplier_.s_address (TEXT), joins.supplier_.s_comment (TEXT), 
joins.supplier_.s_name (TEXT), joins.supplier_.s_nationkey (INT4), 
joins.supplier_.s_phone (TEXT), joins.supplier_.s_suppkey (INT4)
               => out schema: {(7) joins.supplier_.s_acctbal (FLOAT8), 
joins.supplier_.s_address (TEXT), joins.supplier_.s_comment (TEXT), 
joins.supplier_.s_name (TEXT), joins.supplier_.s_nationkey (INT4), 
joins.supplier_.s_phone (TEXT), joins.supplier_.s_suppkey (INT4)}
               => in schema: {(7) joins.supplier_.s_acctbal (FLOAT8), 
joins.supplier_.s_address (TEXT), joins.supplier_.s_comment (TEXT), 
joins.supplier_.s_name (TEXT), joins.supplier_.s_nationkey (INT4), 
joins.supplier_.s_phone (TEXT), joins.supplier_.s_suppkey (INT4)}
+            SCAN(2) on default.partsupp
+              => target list: default.partsupp.ps_partkey (INT4), 
default.partsupp.ps_suppkey (INT4)
+              => out schema: {(2) default.partsupp.ps_partkey (INT4), 
default.partsupp.ps_suppkey (INT4)}
+              => in schema: {(5) default.partsupp.ps_availqty (INT4), 
default.partsupp.ps_comment (TEXT), default.partsupp.ps_partkey (INT4), 
default.partsupp.ps_suppkey (INT4), default.partsupp.ps_supplycost (FLOAT8)}
 explain
 -------------------------------
 -------------------------------------------------------------------------------
@@ -79,137 +79,137 @@ Block Id: eb_0000000000000_0000_000001 [LEAF]
 =======================================================
 
 [Outgoing]
-[q_0000000000000_0000] 1 => 3 (type=HASH_SHUFFLE, 
key=joins.supplier_.s_nationkey (INT4), num=32)
+[q_0000000000000_0000] 1 => 3 (type=HASH_SHUFFLE, 
key=default.partsupp.ps_suppkey (INT4), num=32)
 
-SCAN(1) on joins.supplier_
-  => target list: joins.supplier_.s_acctbal (FLOAT8), 
joins.supplier_.s_address (TEXT), joins.supplier_.s_comment (TEXT), 
joins.supplier_.s_name (TEXT), joins.supplier_.s_nationkey (INT4), 
joins.supplier_.s_phone (TEXT), joins.supplier_.s_suppkey (INT4)
-  => out schema: {(7) joins.supplier_.s_acctbal (FLOAT8), 
joins.supplier_.s_address (TEXT), joins.supplier_.s_comment (TEXT), 
joins.supplier_.s_name (TEXT), joins.supplier_.s_nationkey (INT4), 
joins.supplier_.s_phone (TEXT), joins.supplier_.s_suppkey (INT4)}
-  => in schema: {(7) joins.supplier_.s_acctbal (FLOAT8), 
joins.supplier_.s_address (TEXT), joins.supplier_.s_comment (TEXT), 
joins.supplier_.s_name (TEXT), joins.supplier_.s_nationkey (INT4), 
joins.supplier_.s_phone (TEXT), joins.supplier_.s_suppkey (INT4)}
+SCAN(2) on default.partsupp
+  => target list: default.partsupp.ps_partkey (INT4), 
default.partsupp.ps_suppkey (INT4)
+  => out schema: {(2) default.partsupp.ps_partkey (INT4), 
default.partsupp.ps_suppkey (INT4)}
+  => in schema: {(5) default.partsupp.ps_availqty (INT4), 
default.partsupp.ps_comment (TEXT), default.partsupp.ps_partkey (INT4), 
default.partsupp.ps_suppkey (INT4), default.partsupp.ps_supplycost (FLOAT8)}
 
 =======================================================
 Block Id: eb_0000000000000_0000_000002 [LEAF]
 =======================================================
 
 [Outgoing]
-[q_0000000000000_0000] 2 => 3 (type=HASH_SHUFFLE, 
key=default.nation.n_nationkey (INT4), num=32)
+[q_0000000000000_0000] 2 => 3 (type=HASH_SHUFFLE, 
key=joins.supplier_.s_suppkey (INT4), num=32)
 
-SCAN(3) on default.nation
-  => target list: default.nation.n_name (TEXT), default.nation.n_nationkey 
(INT4), default.nation.n_regionkey (INT4)
-  => out schema: {(3) default.nation.n_name (TEXT), default.nation.n_nationkey 
(INT4), default.nation.n_regionkey (INT4)}
-  => in schema: {(4) default.nation.n_comment (TEXT), default.nation.n_name 
(TEXT), default.nation.n_nationkey (INT4), default.nation.n_regionkey (INT4)}
+SCAN(1) on joins.supplier_
+  => target list: joins.supplier_.s_acctbal (FLOAT8), 
joins.supplier_.s_address (TEXT), joins.supplier_.s_comment (TEXT), 
joins.supplier_.s_name (TEXT), joins.supplier_.s_nationkey (INT4), 
joins.supplier_.s_phone (TEXT), joins.supplier_.s_suppkey (INT4)
+  => out schema: {(7) joins.supplier_.s_acctbal (FLOAT8), 
joins.supplier_.s_address (TEXT), joins.supplier_.s_comment (TEXT), 
joins.supplier_.s_name (TEXT), joins.supplier_.s_nationkey (INT4), 
joins.supplier_.s_phone (TEXT), joins.supplier_.s_suppkey (INT4)}
+  => in schema: {(7) joins.supplier_.s_acctbal (FLOAT8), 
joins.supplier_.s_address (TEXT), joins.supplier_.s_comment (TEXT), 
joins.supplier_.s_name (TEXT), joins.supplier_.s_nationkey (INT4), 
joins.supplier_.s_phone (TEXT), joins.supplier_.s_suppkey (INT4)}
 
 =======================================================
 Block Id: eb_0000000000000_0000_000003 [INTERMEDIATE]
 =======================================================
 
 [Incoming]
-[q_0000000000000_0000] 1 => 3 (type=HASH_SHUFFLE, 
key=joins.supplier_.s_nationkey (INT4), num=32)
-[q_0000000000000_0000] 2 => 3 (type=HASH_SHUFFLE, 
key=default.nation.n_nationkey (INT4), num=32)
+[q_0000000000000_0000] 1 => 3 (type=HASH_SHUFFLE, 
key=default.partsupp.ps_suppkey (INT4), num=32)
+[q_0000000000000_0000] 2 => 3 (type=HASH_SHUFFLE, 
key=joins.supplier_.s_suppkey (INT4), num=32)
 
 [Outgoing]
-[q_0000000000000_0000] 3 => 5 (type=HASH_SHUFFLE, 
key=default.nation.n_regionkey (INT4), num=32)
+[q_0000000000000_0000] 3 => 5 (type=HASH_SHUFFLE, 
key=default.partsupp.ps_partkey (INT4), num=32)
 
 JOIN(13)(INNER)
-  => Join Cond: joins.supplier_.s_nationkey (INT4) = 
default.nation.n_nationkey (INT4)
-  => target list: default.nation.n_name (TEXT), default.nation.n_regionkey 
(INT4), joins.supplier_.s_acctbal (FLOAT8), joins.supplier_.s_address (TEXT), 
joins.supplier_.s_comment (TEXT), joins.supplier_.s_name (TEXT), 
joins.supplier_.s_phone (TEXT), joins.supplier_.s_suppkey (INT4)
-  => out schema: {(8) default.nation.n_name (TEXT), default.nation.n_regionkey 
(INT4), joins.supplier_.s_acctbal (FLOAT8), joins.supplier_.s_address (TEXT), 
joins.supplier_.s_comment (TEXT), joins.supplier_.s_name (TEXT), 
joins.supplier_.s_phone (TEXT), joins.supplier_.s_suppkey (INT4)}
-  => in schema: {(10) default.nation.n_name (TEXT), default.nation.n_nationkey 
(INT4), default.nation.n_regionkey (INT4), joins.supplier_.s_acctbal (FLOAT8), 
joins.supplier_.s_address (TEXT), joins.supplier_.s_comment (TEXT), 
joins.supplier_.s_name (TEXT), joins.supplier_.s_nationkey (INT4), 
joins.supplier_.s_phone (TEXT), joins.supplier_.s_suppkey (INT4)}
+  => Join Cond: joins.supplier_.s_suppkey (INT4) = default.partsupp.ps_suppkey 
(INT4)
+  => target list: default.partsupp.ps_partkey (INT4), 
joins.supplier_.s_acctbal (FLOAT8), joins.supplier_.s_address (TEXT), 
joins.supplier_.s_comment (TEXT), joins.supplier_.s_name (TEXT), 
joins.supplier_.s_nationkey (INT4), joins.supplier_.s_phone (TEXT)
+  => out schema: {(7) default.partsupp.ps_partkey (INT4), 
joins.supplier_.s_acctbal (FLOAT8), joins.supplier_.s_address (TEXT), 
joins.supplier_.s_comment (TEXT), joins.supplier_.s_name (TEXT), 
joins.supplier_.s_nationkey (INT4), joins.supplier_.s_phone (TEXT)}
+  => in schema: {(9) default.partsupp.ps_partkey (INT4), 
default.partsupp.ps_suppkey (INT4), joins.supplier_.s_acctbal (FLOAT8), 
joins.supplier_.s_address (TEXT), joins.supplier_.s_comment (TEXT), 
joins.supplier_.s_name (TEXT), joins.supplier_.s_nationkey (INT4), 
joins.supplier_.s_phone (TEXT), joins.supplier_.s_suppkey (INT4)}
    SCAN(19) on eb_0000000000000_0000_000002
-     => out schema: {(3) default.nation.n_name (TEXT), 
default.nation.n_nationkey (INT4), default.nation.n_regionkey (INT4)}
-     => in schema: {(3) default.nation.n_name (TEXT), 
default.nation.n_nationkey (INT4), default.nation.n_regionkey (INT4)}
-   SCAN(18) on eb_0000000000000_0000_000001
      => out schema: {(7) joins.supplier_.s_acctbal (FLOAT8), 
joins.supplier_.s_address (TEXT), joins.supplier_.s_comment (TEXT), 
joins.supplier_.s_name (TEXT), joins.supplier_.s_nationkey (INT4), 
joins.supplier_.s_phone (TEXT), joins.supplier_.s_suppkey (INT4)}
      => in schema: {(7) joins.supplier_.s_acctbal (FLOAT8), 
joins.supplier_.s_address (TEXT), joins.supplier_.s_comment (TEXT), 
joins.supplier_.s_name (TEXT), joins.supplier_.s_nationkey (INT4), 
joins.supplier_.s_phone (TEXT), joins.supplier_.s_suppkey (INT4)}
+   SCAN(18) on eb_0000000000000_0000_000001
+     => out schema: {(2) default.partsupp.ps_partkey (INT4), 
default.partsupp.ps_suppkey (INT4)}
+     => in schema: {(2) default.partsupp.ps_partkey (INT4), 
default.partsupp.ps_suppkey (INT4)}
 
 =======================================================
 Block Id: eb_0000000000000_0000_000004 [LEAF]
 =======================================================
 
 [Outgoing]
-[q_0000000000000_0000] 4 => 5 (type=HASH_SHUFFLE, 
key=default.region.r_regionkey (INT4), num=32)
+[q_0000000000000_0000] 4 => 5 (type=HASH_SHUFFLE, key=joins.part_.p_partkey 
(INT4), num=32)
 
-SCAN(4) on default.region
-  => target list: default.region.r_regionkey (INT4)
-  => out schema: {(1) default.region.r_regionkey (INT4)}
-  => in schema: {(3) default.region.r_comment (TEXT), default.region.r_name 
(TEXT), default.region.r_regionkey (INT4)}
+SCAN(0) on joins.part_
+  => target list: joins.part_.p_mfgr (TEXT), joins.part_.p_partkey (INT4)
+  => out schema: {(2) joins.part_.p_mfgr (TEXT), joins.part_.p_partkey (INT4)}
+  => in schema: {(9) joins.part_.p_brand (TEXT), joins.part_.p_comment (TEXT), 
joins.part_.p_container (TEXT), joins.part_.p_mfgr (TEXT), joins.part_.p_name 
(TEXT), joins.part_.p_partkey (INT4), joins.part_.p_retailprice (FLOAT8), 
joins.part_.p_size (INT4), joins.part_.p_type (TEXT)}
 
 =======================================================
 Block Id: eb_0000000000000_0000_000006 [LEAF]
 =======================================================
 
 [Outgoing]
-[q_0000000000000_0000] 6 => 8 (type=HASH_SHUFFLE, key=joins.part_.p_partkey 
(INT4), num=32)
+[q_0000000000000_0000] 6 => 8 (type=HASH_SHUFFLE, 
key=default.nation.n_regionkey (INT4), num=32)
 
-SCAN(0) on joins.part_
-  => target list: joins.part_.p_mfgr (TEXT), joins.part_.p_partkey (INT4)
-  => out schema: {(2) joins.part_.p_mfgr (TEXT), joins.part_.p_partkey (INT4)}
-  => in schema: {(9) joins.part_.p_brand (TEXT), joins.part_.p_comment (TEXT), 
joins.part_.p_container (TEXT), joins.part_.p_mfgr (TEXT), joins.part_.p_name 
(TEXT), joins.part_.p_partkey (INT4), joins.part_.p_retailprice (FLOAT8), 
joins.part_.p_size (INT4), joins.part_.p_type (TEXT)}
+SCAN(3) on default.nation
+  => target list: default.nation.n_name (TEXT), default.nation.n_nationkey 
(INT4), default.nation.n_regionkey (INT4)
+  => out schema: {(3) default.nation.n_name (TEXT), default.nation.n_nationkey 
(INT4), default.nation.n_regionkey (INT4)}
+  => in schema: {(4) default.nation.n_comment (TEXT), default.nation.n_name 
(TEXT), default.nation.n_nationkey (INT4), default.nation.n_regionkey (INT4)}
 
 =======================================================
 Block Id: eb_0000000000000_0000_000007 [LEAF]
 =======================================================
 
 [Outgoing]
-[q_0000000000000_0000] 7 => 8 (type=HASH_SHUFFLE, 
key=default.partsupp.ps_partkey (INT4), num=32)
+[q_0000000000000_0000] 7 => 8 (type=HASH_SHUFFLE, 
key=default.region.r_regionkey (INT4), num=32)
 
-SCAN(2) on default.partsupp
-  => target list: default.partsupp.ps_partkey (INT4), 
default.partsupp.ps_suppkey (INT4)
-  => out schema: {(2) default.partsupp.ps_partkey (INT4), 
default.partsupp.ps_suppkey (INT4)}
-  => in schema: {(5) default.partsupp.ps_availqty (INT4), 
default.partsupp.ps_comment (TEXT), default.partsupp.ps_partkey (INT4), 
default.partsupp.ps_suppkey (INT4), default.partsupp.ps_supplycost (FLOAT8)}
+SCAN(4) on default.region
+  => target list: default.region.r_regionkey (INT4)
+  => out schema: {(1) default.region.r_regionkey (INT4)}
+  => 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.nation.n_regionkey (INT4), num=32)
-[q_0000000000000_0000] 4 => 5 (type=HASH_SHUFFLE, 
key=default.region.r_regionkey (INT4), num=32)
+[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=joins.part_.p_partkey 
(INT4), num=32)
 
 [Outgoing]
-[q_0000000000000_0000] 5 => 9 (type=HASH_SHUFFLE, 
key=joins.supplier_.s_suppkey (INT4), num=32)
+[q_0000000000000_0000] 5 => 9 (type=HASH_SHUFFLE, 
key=joins.supplier_.s_nationkey (INT4), num=32)
 
 JOIN(14)(INNER)
-  => Join Cond: default.nation.n_regionkey (INT4) = default.region.r_regionkey 
(INT4)
-  => target list: default.nation.n_name (TEXT), joins.supplier_.s_acctbal 
(FLOAT8), joins.supplier_.s_address (TEXT), joins.supplier_.s_comment (TEXT), 
joins.supplier_.s_name (TEXT), joins.supplier_.s_phone (TEXT), 
joins.supplier_.s_suppkey (INT4)
-  => out schema: {(7) default.nation.n_name (TEXT), joins.supplier_.s_acctbal 
(FLOAT8), joins.supplier_.s_address (TEXT), joins.supplier_.s_comment (TEXT), 
joins.supplier_.s_name (TEXT), joins.supplier_.s_phone (TEXT), 
joins.supplier_.s_suppkey (INT4)}
-  => in schema: {(9) default.nation.n_name (TEXT), default.nation.n_regionkey 
(INT4), default.region.r_regionkey (INT4), joins.supplier_.s_acctbal (FLOAT8), 
joins.supplier_.s_address (TEXT), joins.supplier_.s_comment (TEXT), 
joins.supplier_.s_name (TEXT), joins.supplier_.s_phone (TEXT), 
joins.supplier_.s_suppkey (INT4)}
+  => Join Cond: joins.part_.p_partkey (INT4) = default.partsupp.ps_partkey 
(INT4)
+  => target list: joins.part_.p_mfgr (TEXT), joins.part_.p_partkey (INT4), 
joins.supplier_.s_acctbal (FLOAT8), joins.supplier_.s_address (TEXT), 
joins.supplier_.s_comment (TEXT), joins.supplier_.s_name (TEXT), 
joins.supplier_.s_nationkey (INT4), joins.supplier_.s_phone (TEXT)
+  => out schema: {(8) joins.part_.p_mfgr (TEXT), joins.part_.p_partkey (INT4), 
joins.supplier_.s_acctbal (FLOAT8), joins.supplier_.s_address (TEXT), 
joins.supplier_.s_comment (TEXT), joins.supplier_.s_name (TEXT), 
joins.supplier_.s_nationkey (INT4), joins.supplier_.s_phone (TEXT)}
+  => in schema: {(9) default.partsupp.ps_partkey (INT4), joins.part_.p_mfgr 
(TEXT), joins.part_.p_partkey (INT4), joins.supplier_.s_acctbal (FLOAT8), 
joins.supplier_.s_address (TEXT), joins.supplier_.s_comment (TEXT), 
joins.supplier_.s_name (TEXT), joins.supplier_.s_nationkey (INT4), 
joins.supplier_.s_phone (TEXT)}
    SCAN(21) on eb_0000000000000_0000_000004
-     => out schema: {(1) default.region.r_regionkey (INT4)}
-     => in schema: {(1) default.region.r_regionkey (INT4)}
+     => out schema: {(2) joins.part_.p_mfgr (TEXT), joins.part_.p_partkey 
(INT4)}
+     => in schema: {(2) joins.part_.p_mfgr (TEXT), joins.part_.p_partkey 
(INT4)}
    SCAN(20) on eb_0000000000000_0000_000003
-     => out schema: {(8) default.nation.n_name (TEXT), 
default.nation.n_regionkey (INT4), joins.supplier_.s_acctbal (FLOAT8), 
joins.supplier_.s_address (TEXT), joins.supplier_.s_comment (TEXT), 
joins.supplier_.s_name (TEXT), joins.supplier_.s_phone (TEXT), 
joins.supplier_.s_suppkey (INT4)}
-     => in schema: {(8) default.nation.n_name (TEXT), 
default.nation.n_regionkey (INT4), joins.supplier_.s_acctbal (FLOAT8), 
joins.supplier_.s_address (TEXT), joins.supplier_.s_comment (TEXT), 
joins.supplier_.s_name (TEXT), joins.supplier_.s_phone (TEXT), 
joins.supplier_.s_suppkey (INT4)}
+     => out schema: {(7) default.partsupp.ps_partkey (INT4), 
joins.supplier_.s_acctbal (FLOAT8), joins.supplier_.s_address (TEXT), 
joins.supplier_.s_comment (TEXT), joins.supplier_.s_name (TEXT), 
joins.supplier_.s_nationkey (INT4), joins.supplier_.s_phone (TEXT)}
+     => in schema: {(7) default.partsupp.ps_partkey (INT4), 
joins.supplier_.s_acctbal (FLOAT8), joins.supplier_.s_address (TEXT), 
joins.supplier_.s_comment (TEXT), joins.supplier_.s_name (TEXT), 
joins.supplier_.s_nationkey (INT4), joins.supplier_.s_phone (TEXT)}
 
 =======================================================
 Block Id: eb_0000000000000_0000_000008 [INTERMEDIATE]
 =======================================================
 
 [Incoming]
-[q_0000000000000_0000] 6 => 8 (type=HASH_SHUFFLE, key=joins.part_.p_partkey 
(INT4), num=32)
-[q_0000000000000_0000] 7 => 8 (type=HASH_SHUFFLE, 
key=default.partsupp.ps_partkey (INT4), num=32)
+[q_0000000000000_0000] 6 => 8 (type=HASH_SHUFFLE, 
key=default.nation.n_regionkey (INT4), num=32)
+[q_0000000000000_0000] 7 => 8 (type=HASH_SHUFFLE, 
key=default.region.r_regionkey (INT4), num=32)
 
 [Outgoing]
-[q_0000000000000_0000] 8 => 9 (type=HASH_SHUFFLE, 
key=default.partsupp.ps_suppkey (INT4), num=32)
+[q_0000000000000_0000] 8 => 9 (type=HASH_SHUFFLE, 
key=default.nation.n_nationkey (INT4), num=32)
 
 JOIN(15)(INNER)
-  => Join Cond: joins.part_.p_partkey (INT4) = default.partsupp.ps_partkey 
(INT4)
-  => target list: default.partsupp.ps_suppkey (INT4), joins.part_.p_mfgr 
(TEXT), joins.part_.p_partkey (INT4)
-  => out schema: {(3) default.partsupp.ps_suppkey (INT4), joins.part_.p_mfgr 
(TEXT), joins.part_.p_partkey (INT4)}
-  => in schema: {(4) default.partsupp.ps_partkey (INT4), 
default.partsupp.ps_suppkey (INT4), joins.part_.p_mfgr (TEXT), 
joins.part_.p_partkey (INT4)}
+  => Join Cond: default.nation.n_regionkey (INT4) = default.region.r_regionkey 
(INT4)
+  => target list: default.nation.n_name (TEXT), default.nation.n_nationkey 
(INT4)
+  => out schema: {(2) default.nation.n_name (TEXT), default.nation.n_nationkey 
(INT4)}
+  => in schema: {(4) default.nation.n_name (TEXT), default.nation.n_nationkey 
(INT4), default.nation.n_regionkey (INT4), default.region.r_regionkey (INT4)}
    SCAN(23) on eb_0000000000000_0000_000007
-     => out schema: {(2) default.partsupp.ps_partkey (INT4), 
default.partsupp.ps_suppkey (INT4)}
-     => in schema: {(2) default.partsupp.ps_partkey (INT4), 
default.partsupp.ps_suppkey (INT4)}
+     => out schema: {(1) default.region.r_regionkey (INT4)}
+     => in schema: {(1) default.region.r_regionkey (INT4)}
    SCAN(22) on eb_0000000000000_0000_000006
-     => out schema: {(2) joins.part_.p_mfgr (TEXT), joins.part_.p_partkey 
(INT4)}
-     => in schema: {(2) joins.part_.p_mfgr (TEXT), joins.part_.p_partkey 
(INT4)}
+     => out schema: {(3) default.nation.n_name (TEXT), 
default.nation.n_nationkey (INT4), default.nation.n_regionkey (INT4)}
+     => in schema: {(3) default.nation.n_name (TEXT), 
default.nation.n_nationkey (INT4), default.nation.n_regionkey (INT4)}
 
 =======================================================
 Block Id: eb_0000000000000_0000_000009 [INTERMEDIATE]
 =======================================================
 
 [Incoming]
-[q_0000000000000_0000] 5 => 9 (type=HASH_SHUFFLE, 
key=joins.supplier_.s_suppkey (INT4), num=32)
-[q_0000000000000_0000] 8 => 9 (type=HASH_SHUFFLE, 
key=default.partsupp.ps_suppkey (INT4), num=32)
+[q_0000000000000_0000] 5 => 9 (type=HASH_SHUFFLE, 
key=joins.supplier_.s_nationkey (INT4), num=32)
+[q_0000000000000_0000] 8 => 9 (type=HASH_SHUFFLE, 
key=default.nation.n_nationkey (INT4), num=32)
 
 [Outgoing]
 [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)
@@ -217,16 +217,16 @@ Block Id: eb_0000000000000_0000_000009 [INTERMEDIATE]
 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)
    JOIN(16)(INNER)
-     => Join Cond: joins.supplier_.s_suppkey (INT4) = 
default.partsupp.ps_suppkey (INT4)
+     => Join Cond: joins.supplier_.s_nationkey (INT4) = 
default.nation.n_nationkey (INT4)
      => target list: default.nation.n_name (TEXT), joins.part_.p_mfgr (TEXT), 
joins.part_.p_partkey (INT4), joins.supplier_.s_acctbal (FLOAT8), 
joins.supplier_.s_address (TEXT), joins.supplier_.s_comment (TEXT), 
joins.supplier_.s_name (TEXT), joins.supplier_.s_phone (TEXT)
      => out schema: {(8) default.nation.n_name (TEXT), joins.part_.p_mfgr 
(TEXT), joins.part_.p_partkey (INT4), joins.supplier_.s_acctbal (FLOAT8), 
joins.supplier_.s_address (TEXT), joins.supplier_.s_comment (TEXT), 
joins.supplier_.s_name (TEXT), joins.supplier_.s_phone (TEXT)}
-     => in schema: {(10) default.nation.n_name (TEXT), 
default.partsupp.ps_suppkey (INT4), joins.part_.p_mfgr (TEXT), 
joins.part_.p_partkey (INT4), joins.supplier_.s_acctbal (FLOAT8), 
joins.supplier_.s_address (TEXT), joins.supplier_.s_comment (TEXT), 
joins.supplier_.s_name (TEXT), joins.supplier_.s_phone (TEXT), 
joins.supplier_.s_suppkey (INT4)}
+     => in schema: {(10) default.nation.n_name (TEXT), 
default.nation.n_nationkey (INT4), joins.part_.p_mfgr (TEXT), 
joins.part_.p_partkey (INT4), joins.supplier_.s_acctbal (FLOAT8), 
joins.supplier_.s_address (TEXT), joins.supplier_.s_comment (TEXT), 
joins.supplier_.s_name (TEXT), joins.supplier_.s_nationkey (INT4), 
joins.supplier_.s_phone (TEXT)}
       SCAN(25) on eb_0000000000000_0000_000008
-        => out schema: {(3) default.partsupp.ps_suppkey (INT4), 
joins.part_.p_mfgr (TEXT), joins.part_.p_partkey (INT4)}
-        => in schema: {(3) default.partsupp.ps_suppkey (INT4), 
joins.part_.p_mfgr (TEXT), joins.part_.p_partkey (INT4)}
+        => out schema: {(2) default.nation.n_name (TEXT), 
default.nation.n_nationkey (INT4)}
+        => in schema: {(2) default.nation.n_name (TEXT), 
default.nation.n_nationkey (INT4)}
       SCAN(24) on eb_0000000000000_0000_000005
-        => out schema: {(7) default.nation.n_name (TEXT), 
joins.supplier_.s_acctbal (FLOAT8), joins.supplier_.s_address (TEXT), 
joins.supplier_.s_comment (TEXT), joins.supplier_.s_name (TEXT), 
joins.supplier_.s_phone (TEXT), joins.supplier_.s_suppkey (INT4)}
-        => in schema: {(7) default.nation.n_name (TEXT), 
joins.supplier_.s_acctbal (FLOAT8), joins.supplier_.s_address (TEXT), 
joins.supplier_.s_comment (TEXT), joins.supplier_.s_name (TEXT), 
joins.supplier_.s_phone (TEXT), joins.supplier_.s_suppkey (INT4)}
+        => out schema: {(8) joins.part_.p_mfgr (TEXT), joins.part_.p_partkey 
(INT4), joins.supplier_.s_acctbal (FLOAT8), joins.supplier_.s_address (TEXT), 
joins.supplier_.s_comment (TEXT), joins.supplier_.s_name (TEXT), 
joins.supplier_.s_nationkey (INT4), joins.supplier_.s_phone (TEXT)}
+        => in schema: {(8) joins.part_.p_mfgr (TEXT), joins.part_.p_partkey 
(INT4), joins.supplier_.s_acctbal (FLOAT8), joins.supplier_.s_address (TEXT), 
joins.supplier_.s_comment (TEXT), joins.supplier_.s_name (TEXT), 
joins.supplier_.s_nationkey (INT4), joins.supplier_.s_phone (TEXT)}
 
 =======================================================
 Block Id: eb_0000000000000_0000_000010 [ROOT]