asterixdb-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ima...@apache.org
Subject [37/85] [abbrv] [partial] incubator-asterixdb-hyracks git commit: Move Pregelix and Hivesterix codebase to new repositories: 1. Move Pregelix codebase to https://github.com/pregelix/pregelix; 2. Move Hivesterix codebase to https://code.google.com/p/hives
Date Fri, 24 Apr 2015 18:46:04 GMT
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/ffc967fd/hivesterix/hivesterix-dist/src/test/resources/optimizerts/results/q1_pricing_summary_report.plan
----------------------------------------------------------------------
diff --git a/hivesterix/hivesterix-dist/src/test/resources/optimizerts/results/q1_pricing_summary_report.plan b/hivesterix/hivesterix-dist/src/test/resources/optimizerts/results/q1_pricing_summary_report.plan
deleted file mode 100644
index 3505205..0000000
--- a/hivesterix/hivesterix-dist/src/test/resources/optimizerts/results/q1_pricing_summary_report.plan
+++ /dev/null
@@ -1,38 +0,0 @@
-write [%0->$$17, %0->$$18, %0->$$19, %0->$$20, %0->$$21, %0->$$22, %0->$$23, %0->$$24, %0->$$25, %0->$$27]
--- SINK_WRITE  |PARTITIONED|
-  project ([$$17, $$18, $$19, $$20, $$21, $$22, $$23, $$24, $$25, $$27])
-  -- STREAM_PROJECT  |PARTITIONED|
-    assign [$$27] <- [function-call: hive:org.apache.hadoop.hive.ql.udf.UDFToInteger, Args:[%0->$$26]]
-    -- ASSIGN  |PARTITIONED|
-      exchange 
-      -- SORT_MERGE_EXCHANGE [$$17(ASC), $$18(ASC) ]  |PARTITIONED|
-        group by ([$$17 := %0->$$37; $$18 := %0->$$38]) decor ([]) {
-                  aggregate [$$19, $$20, $$21, $$22, $$23, $$24, $$25, $$26] <- [function-call: hive:sum(FINAL), Args:[%0->$$29], function-call: hive:sum(FINAL), Args:[%0->$$30], function-call: hive:sum(FINAL), Args:[%0->$$31], function-call: hive:sum(FINAL), Args:[%0->$$32], function-call: hive:avg(FINAL), Args:[%0->$$33], function-call: hive:avg(FINAL), Args:[%0->$$34], function-call: hive:avg(FINAL), Args:[%0->$$35], function-call: hive:count(FINAL), Args:[%0->$$36]]
-                  -- AGGREGATE  |LOCAL|
-                    nested tuple source
-                    -- NESTED_TUPLE_SOURCE  |LOCAL|
-               }
-        -- PRE_CLUSTERED_GROUP_BY[$$37, $$38]  |PARTITIONED|
-          exchange 
-          -- HASH_PARTITION_MERGE_EXCHANGE MERGE:[$$37(ASC), $$38(ASC)] HASH:[$$37, $$38]  |PARTITIONED|
-            group by ([$$37 := %0->$$9; $$38 := %0->$$10]) decor ([]) {
-                      aggregate [$$29, $$30, $$31, $$32, $$33, $$34, $$35, $$36] <- [function-call: hive:sum(PARTIAL1), Args:[%0->$$5], function-call: hive:sum(PARTIAL1), Args:[%0->$$6], function-call: hive:sum(PARTIAL1), Args:[function-call: hive:org.apache.hadoop.hive.ql.udf.UDFOPMultiply, Args:[%0->$$6, function-call: hive:org.apache.hadoop.hive.ql.udf.UDFOPMinus, Args:[1, %0->$$7]]], function-call: hive:sum(PARTIAL1), Args:[function-call: hive:org.apache.hadoop.hive.ql.udf.UDFOPMultiply, Args:[function-call: hive:org.apache.hadoop.hive.ql.udf.UDFOPMultiply, Args:[%0->$$6, function-call: hive:org.apache.hadoop.hive.ql.udf.UDFOPMinus, Args:[1, %0->$$7]], function-call: hive:org.apache.hadoop.hive.ql.udf.UDFOPPlus, Args:[1, %0->$$8]]], function-call: hive:avg(PARTIAL1), Args:[%0->$$5], function-call: hive:avg(PARTIAL1), Args:[%0->$$6], function-call: hive:avg(PARTIAL1), Args:[%0->$$7], function-call: hive:count(PARTIAL1), Args:[1]]
-                      -- AGGREGATE  |LOCAL|
-                        nested tuple source
-                        -- NESTED_TUPLE_SOURCE  |LOCAL|
-                   }
-            -- SORT_GROUP_BY[$$9, $$10]  |PARTITIONED|
-              exchange 
-              -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                project ([$$9, $$10, $$5, $$6, $$7, $$8])
-                -- STREAM_PROJECT  |PARTITIONED|
-                  select (function-call: algebricks:le, Args:[%0->$$11, 1998-09-02])
-                  -- STREAM_SELECT  |PARTITIONED|
-                    exchange 
-                    -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                      data-scan [$$5, $$6, $$7, $$8, $$9, $$10, $$11]<-[$$1, $$2, $$3, $$4, $$5, $$6, $$7, $$8, $$9, $$10, $$11, $$12, $$13, $$14, $$15, $$16] <- default.lineitem
-                      -- DATASOURCE_SCAN  |PARTITIONED|
-                        exchange 
-                        -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                          empty-tuple-source
-                          -- EMPTY_TUPLE_SOURCE  |PARTITIONED|

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/ffc967fd/hivesterix/hivesterix-dist/src/test/resources/optimizerts/results/q20_potential_part_promotion.plan
----------------------------------------------------------------------
diff --git a/hivesterix/hivesterix-dist/src/test/resources/optimizerts/results/q20_potential_part_promotion.plan b/hivesterix/hivesterix-dist/src/test/resources/optimizerts/results/q20_potential_part_promotion.plan
deleted file mode 100644
index cecf482..0000000
--- a/hivesterix/hivesterix-dist/src/test/resources/optimizerts/results/q20_potential_part_promotion.plan
+++ /dev/null
@@ -1,178 +0,0 @@
-write [%0->$$1]
--- SINK_WRITE  |PARTITIONED|
-  exchange 
-  -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-    distinct ([%0->$$1])
-    -- PRE_SORTED_DISTINCT_BY  |PARTITIONED|
-      exchange 
-      -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-        order (ASC, %0->$$1) 
-        -- STABLE_SORT [$$1(ASC)]  |PARTITIONED|
-          exchange 
-          -- HASH_PARTITION_EXCHANGE [$$1]  |PARTITIONED|
-            project ([$$1])
-            -- STREAM_PROJECT  |PARTITIONED|
-              select (function-call: hive:org.apache.hadoop.hive.ql.udf.UDFLike, Args:[%0->$$2, forest%])
-              -- STREAM_SELECT  |PARTITIONED|
-                exchange 
-                -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                  data-scan [$$1, $$2]<-[$$1, $$2, $$3, $$4, $$5, $$6, $$7, $$8, $$9] <- default.part
-                  -- DATASOURCE_SCAN  |PARTITIONED|
-                    exchange 
-                    -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                      empty-tuple-source
-                      -- EMPTY_TUPLE_SOURCE  |PARTITIONED|
-write [%0->$$17, %0->$$18, %0->$$20]
--- SINK_WRITE  |PARTITIONED|
-  project ([$$17, $$18, $$20])
-  -- STREAM_PROJECT  |PARTITIONED|
-    assign [$$20] <- [function-call: hive:org.apache.hadoop.hive.ql.udf.UDFOPMultiply, Args:[0.5, %0->$$19]]
-    -- ASSIGN  |PARTITIONED|
-      exchange 
-      -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-        group by ([$$17 := %0->$$23; $$18 := %0->$$24]) decor ([]) {
-                  aggregate [$$19] <- [function-call: hive:sum(FINAL), Args:[%0->$$22]]
-                  -- AGGREGATE  |LOCAL|
-                    nested tuple source
-                    -- NESTED_TUPLE_SOURCE  |LOCAL|
-               }
-        -- PRE_CLUSTERED_GROUP_BY[$$23, $$24]  |PARTITIONED|
-          exchange 
-          -- HASH_PARTITION_MERGE_EXCHANGE MERGE:[$$23(ASC), $$24(ASC)] HASH:[$$23, $$24]  |PARTITIONED|
-            group by ([$$23 := %0->$$2; $$24 := %0->$$3]) decor ([]) {
-                      aggregate [$$22] <- [function-call: hive:sum(PARTIAL1), Args:[%0->$$5]]
-                      -- AGGREGATE  |LOCAL|
-                        nested tuple source
-                        -- NESTED_TUPLE_SOURCE  |LOCAL|
-                   }
-            -- SORT_GROUP_BY[$$2, $$3]  |PARTITIONED|
-              exchange 
-              -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                project ([$$2, $$3, $$5])
-                -- STREAM_PROJECT  |PARTITIONED|
-                  select (function-call: algebricks:and, Args:[function-call: algebricks:ge, Args:[%0->$$11, 1994-01-01], function-call: algebricks:lt, Args:[%0->$$11, 1995-01-01]])
-                  -- STREAM_SELECT  |PARTITIONED|
-                    exchange 
-                    -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                      data-scan [$$2, $$3, $$5, $$11]<-[$$1, $$2, $$3, $$4, $$5, $$6, $$7, $$8, $$9, $$10, $$11, $$12, $$13, $$14, $$15, $$16] <- default.lineitem
-                      -- DATASOURCE_SCAN  |PARTITIONED|
-                        exchange 
-                        -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                          empty-tuple-source
-                          -- EMPTY_TUPLE_SOURCE  |PARTITIONED|
-write [%0->$$6, %0->$$7, %0->$$3]
--- SINK_WRITE  |PARTITIONED|
-  project ([$$6, $$7, $$3])
-  -- STREAM_PROJECT  |PARTITIONED|
-    exchange 
-    -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-      join (function-call: algebricks:and, Args:[function-call: algebricks:eq, Args:[%0->$$1, %0->$$5], function-call: algebricks:eq, Args:[%0->$$2, %0->$$6]])
-      -- HYBRID_HASH_JOIN [$$1, $$2][$$5, $$6]  |PARTITIONED|
-        exchange 
-        -- HASH_PARTITION_EXCHANGE [$$1, $$2]  |PARTITIONED|
-          data-scan []<-[$$1, $$2, $$3] <- default.q20_tmp2
-          -- DATASOURCE_SCAN  |PARTITIONED|
-            exchange 
-            -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-              empty-tuple-source
-              -- EMPTY_TUPLE_SOURCE  |PARTITIONED|
-        exchange 
-        -- HASH_PARTITION_EXCHANGE [$$5, $$6]  |PARTITIONED|
-          project ([$$5, $$6, $$7])
-          -- STREAM_PROJECT  |PARTITIONED|
-            exchange 
-            -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-              join (function-call: algebricks:eq, Args:[%0->$$4, %0->$$5])
-              -- HYBRID_HASH_JOIN [$$4][$$5]  |PARTITIONED|
-                exchange 
-                -- HASH_PARTITION_EXCHANGE [$$4]  |PARTITIONED|
-                  data-scan []<-[$$4] <- default.q20_tmp1
-                  -- DATASOURCE_SCAN  |PARTITIONED|
-                    exchange 
-                    -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                      empty-tuple-source
-                      -- EMPTY_TUPLE_SOURCE  |PARTITIONED|
-                exchange 
-                -- HASH_PARTITION_EXCHANGE [$$5]  |PARTITIONED|
-                  data-scan [$$5, $$6, $$7]<-[$$5, $$6, $$7, $$8, $$9] <- default.partsupp
-                  -- DATASOURCE_SCAN  |PARTITIONED|
-                    exchange 
-                    -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                      empty-tuple-source
-                      -- EMPTY_TUPLE_SOURCE  |PARTITIONED|
-write [%0->$$1]
--- SINK_WRITE  |PARTITIONED|
-  exchange 
-  -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-    distinct ([%0->$$1])
-    -- PRE_SORTED_DISTINCT_BY  |PARTITIONED|
-      exchange 
-      -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-        order (ASC, %0->$$1) 
-        -- STABLE_SORT [$$1(ASC)]  |PARTITIONED|
-          exchange 
-          -- HASH_PARTITION_EXCHANGE [$$1]  |PARTITIONED|
-            project ([$$1])
-            -- STREAM_PROJECT  |PARTITIONED|
-              select (function-call: algebricks:gt, Args:[%0->$$2, %0->$$3])
-              -- STREAM_SELECT  |PARTITIONED|
-                exchange 
-                -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                  data-scan []<-[$$1, $$2, $$3] <- default.q20_tmp3
-                  -- DATASOURCE_SCAN  |PARTITIONED|
-                    exchange 
-                    -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                      empty-tuple-source
-                      -- EMPTY_TUPLE_SOURCE  |PARTITIONED|
-write [%0->$$3, %0->$$4]
--- SINK_WRITE  |PARTITIONED|
-  exchange 
-  -- SORT_MERGE_EXCHANGE [$$3(ASC) ]  |PARTITIONED|
-    order (ASC, %0->$$3) 
-    -- STABLE_SORT [$$3(ASC)]  |PARTITIONED|
-      exchange 
-      -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-        project ([$$3, $$4])
-        -- STREAM_PROJECT  |PARTITIONED|
-          exchange 
-          -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-            join (function-call: algebricks:eq, Args:[%0->$$1, %0->$$2])
-            -- HYBRID_HASH_JOIN [$$1][$$2]  |PARTITIONED|
-              exchange 
-              -- HASH_PARTITION_EXCHANGE [$$1]  |PARTITIONED|
-                data-scan []<-[$$1] <- default.q20_tmp4
-                -- DATASOURCE_SCAN  |PARTITIONED|
-                  exchange 
-                  -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                    empty-tuple-source
-                    -- EMPTY_TUPLE_SOURCE  |PARTITIONED|
-              exchange 
-              -- HASH_PARTITION_EXCHANGE [$$2]  |PARTITIONED|
-                project ([$$2, $$3, $$4])
-                -- STREAM_PROJECT  |PARTITIONED|
-                  exchange 
-                  -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                    join (function-call: algebricks:eq, Args:[%0->$$9, %0->$$5])
-                    -- HYBRID_HASH_JOIN [$$9][$$5]  |PARTITIONED|
-                      exchange 
-                      -- HASH_PARTITION_EXCHANGE [$$9]  |PARTITIONED|
-                        project ([$$9])
-                        -- STREAM_PROJECT  |PARTITIONED|
-                          select (function-call: algebricks:eq, Args:[%0->$$10, CANADA])
-                          -- STREAM_SELECT  |PARTITIONED|
-                            exchange 
-                            -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                              data-scan [$$9, $$10]<-[$$9, $$10, $$11, $$12] <- default.nation
-                              -- DATASOURCE_SCAN  |PARTITIONED|
-                                exchange 
-                                -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                                  empty-tuple-source
-                                  -- EMPTY_TUPLE_SOURCE  |PARTITIONED|
-                      exchange 
-                      -- HASH_PARTITION_EXCHANGE [$$5]  |PARTITIONED|
-                        data-scan [$$5, $$2, $$3, $$4]<-[$$2, $$3, $$4, $$5, $$6, $$7, $$8] <- default.supplier
-                        -- DATASOURCE_SCAN  |PARTITIONED|
-                          exchange 
-                          -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                            empty-tuple-source
-                            -- EMPTY_TUPLE_SOURCE  |PARTITIONED|

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/ffc967fd/hivesterix/hivesterix-dist/src/test/resources/optimizerts/results/q21_suppliers_who_kept_orders_waiting.plan
----------------------------------------------------------------------
diff --git a/hivesterix/hivesterix-dist/src/test/resources/optimizerts/results/q21_suppliers_who_kept_orders_waiting.plan b/hivesterix/hivesterix-dist/src/test/resources/optimizerts/results/q21_suppliers_who_kept_orders_waiting.plan
deleted file mode 100644
index 28bc66b..0000000
--- a/hivesterix/hivesterix-dist/src/test/resources/optimizerts/results/q21_suppliers_who_kept_orders_waiting.plan
+++ /dev/null
@@ -1,216 +0,0 @@
-write [%0->$$21, %0->$$24, %0->$$23]
--- SINK_WRITE  |PARTITIONED|
-  project ([$$21, $$24, $$23])
-  -- STREAM_PROJECT  |PARTITIONED|
-    assign [$$24] <- [function-call: hive:org.apache.hadoop.hive.ql.udf.UDFToInteger, Args:[%0->$$22]]
-    -- ASSIGN  |PARTITIONED|
-      exchange 
-      -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-        group by ([$$21 := %0->$$17]) decor ([]) {
-                  aggregate [$$22, $$23] <- [function-call: hive:count(COMPLETE), Args:[%0->$$18], function-call: hive:max(FINAL), Args:[%0->$$20]]
-                  -- AGGREGATE  |LOCAL|
-                    nested tuple source
-                    -- NESTED_TUPLE_SOURCE  |LOCAL|
-               }
-        -- PRE_CLUSTERED_GROUP_BY[$$17]  |PARTITIONED|
-          exchange 
-          -- HASH_PARTITION_MERGE_EXCHANGE MERGE:[$$17(ASC), $$18(ASC)] HASH:[$$17]  |PARTITIONED|
-            group by ([$$17 := %0->$$1; $$18 := %0->$$3]) decor ([]) {
-                      aggregate [$$20] <- [function-call: hive:max(PARTIAL1), Args:[%0->$$3]]
-                      -- AGGREGATE  |LOCAL|
-                        nested tuple source
-                        -- NESTED_TUPLE_SOURCE  |LOCAL|
-                   }
-            -- SORT_GROUP_BY[$$1, $$3]  |PARTITIONED|
-              exchange 
-              -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                data-scan [$$1, $$3]<-[$$1, $$2, $$3, $$4, $$5, $$6, $$7, $$8, $$9, $$10, $$11, $$12, $$13, $$14, $$15, $$16] <- default.lineitem
-                -- DATASOURCE_SCAN  |PARTITIONED|
-                  exchange 
-                  -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                    empty-tuple-source
-                    -- EMPTY_TUPLE_SOURCE  |PARTITIONED|
-write [%0->$$21, %0->$$24, %0->$$23]
--- SINK_WRITE  |PARTITIONED|
-  project ([$$21, $$24, $$23])
-  -- STREAM_PROJECT  |PARTITIONED|
-    assign [$$24] <- [function-call: hive:org.apache.hadoop.hive.ql.udf.UDFToInteger, Args:[%0->$$22]]
-    -- ASSIGN  |PARTITIONED|
-      exchange 
-      -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-        group by ([$$21 := %0->$$17]) decor ([]) {
-                  aggregate [$$22, $$23] <- [function-call: hive:count(COMPLETE), Args:[%0->$$18], function-call: hive:max(FINAL), Args:[%0->$$20]]
-                  -- AGGREGATE  |LOCAL|
-                    nested tuple source
-                    -- NESTED_TUPLE_SOURCE  |LOCAL|
-               }
-        -- PRE_CLUSTERED_GROUP_BY[$$17]  |PARTITIONED|
-          exchange 
-          -- HASH_PARTITION_MERGE_EXCHANGE MERGE:[$$17(ASC), $$18(ASC)] HASH:[$$17]  |PARTITIONED|
-            group by ([$$17 := %0->$$1; $$18 := %0->$$3]) decor ([]) {
-                      aggregate [$$20] <- [function-call: hive:max(PARTIAL1), Args:[%0->$$3]]
-                      -- AGGREGATE  |LOCAL|
-                        nested tuple source
-                        -- NESTED_TUPLE_SOURCE  |LOCAL|
-                   }
-            -- SORT_GROUP_BY[$$1, $$3]  |PARTITIONED|
-              exchange 
-              -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                project ([$$1, $$3])
-                -- STREAM_PROJECT  |PARTITIONED|
-                  select (function-call: algebricks:gt, Args:[%0->$$13, %0->$$12])
-                  -- STREAM_SELECT  |PARTITIONED|
-                    exchange 
-                    -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                      data-scan [$$1, $$3, $$12, $$13]<-[$$1, $$2, $$3, $$4, $$5, $$6, $$7, $$8, $$9, $$10, $$11, $$12, $$13, $$14, $$15, $$16] <- default.lineitem
-                      -- DATASOURCE_SCAN  |PARTITIONED|
-                        exchange 
-                        -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                          empty-tuple-source
-                          -- EMPTY_TUPLE_SOURCE  |PARTITIONED|
-write [%0->$$43, %0->$$45]
--- SINK_WRITE  |UNPARTITIONED|
-  project ([$$43, $$45])
-  -- STREAM_PROJECT  |UNPARTITIONED|
-    assign [$$45] <- [function-call: hive:org.apache.hadoop.hive.ql.udf.UDFToInteger, Args:[%0->$$44]]
-    -- ASSIGN  |UNPARTITIONED|
-      limit 100
-      -- STREAM_LIMIT  |UNPARTITIONED|
-        limit 100
-        -- STREAM_LIMIT  |UNPARTITIONED|
-          exchange 
-          -- SORT_MERGE_EXCHANGE [$$44(DESC), $$43(ASC) ]  |PARTITIONED|
-            limit 100
-            -- STREAM_LIMIT  |PARTITIONED|
-              exchange 
-              -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                order (DESC, %0->$$44) (ASC, %0->$$43) 
-                -- STABLE_SORT [$$44(DESC), $$43(ASC)]  |PARTITIONED|
-                  exchange 
-                  -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                    group by ([$$43 := %0->$$48]) decor ([]) {
-                              aggregate [$$44] <- [function-call: hive:count(FINAL), Args:[%0->$$47]]
-                              -- AGGREGATE  |LOCAL|
-                                nested tuple source
-                                -- NESTED_TUPLE_SOURCE  |LOCAL|
-                           }
-                    -- PRE_CLUSTERED_GROUP_BY[$$48]  |PARTITIONED|
-                      exchange 
-                      -- HASH_PARTITION_MERGE_EXCHANGE MERGE:[$$48(ASC)] HASH:[$$48]  |PARTITIONED|
-                        group by ([$$48 := %0->$$37]) decor ([]) {
-                                  aggregate [$$47] <- [function-call: hive:count(PARTIAL1), Args:[1]]
-                                  -- AGGREGATE  |LOCAL|
-                                    nested tuple source
-                                    -- NESTED_TUPLE_SOURCE  |LOCAL|
-                               }
-                        -- SORT_GROUP_BY[$$37]  |PARTITIONED|
-                          exchange 
-                          -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                            project ([$$37])
-                            -- STREAM_PROJECT  |PARTITIONED|
-                              select (function-call: algebricks:or, Args:[function-call: hive:org.apache.hadoop.hive.ql.udf.generic.GenericUDFOPNull, Args:[%0->$$2], function-call: algebricks:and, Args:[function-call: algebricks:eq, Args:[%0->$$2, 1], function-call: algebricks:eq, Args:[%0->$$18, %0->$$3]]])
-                              -- STREAM_SELECT  |PARTITIONED|
-                                exchange 
-                                -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                                  left outer join (function-call: algebricks:eq, Args:[%0->$$4, %0->$$1])
-                                  -- HYBRID_HASH_JOIN [$$4][$$1]  |PARTITIONED|
-                                    exchange 
-                                    -- HASH_PARTITION_EXCHANGE [$$4]  |PARTITIONED|
-                                      project ([$$37, $$4, $$18])
-                                      -- STREAM_PROJECT  |PARTITIONED|
-                                        select (function-call: algebricks:or, Args:[function-call: algebricks:gt, Args:[%0->$$5, 1], function-call: algebricks:and, Args:[function-call: algebricks:eq, Args:[%0->$$5, 1], function-call: algebricks:neq, Args:[%0->$$18, %0->$$6]]])
-                                        -- STREAM_SELECT  |PARTITIONED|
-                                          exchange 
-                                          -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                                            join (function-call: algebricks:eq, Args:[%0->$$16, %0->$$4])
-                                            -- HYBRID_HASH_JOIN [$$16][$$4]  |PARTITIONED|
-                                              exchange 
-                                              -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                                                project ([$$37, $$16, $$18])
-                                                -- STREAM_PROJECT  |PARTITIONED|
-                                                  exchange 
-                                                  -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                                                    join (function-call: algebricks:eq, Args:[%0->$$16, %0->$$7])
-                                                    -- HYBRID_HASH_JOIN [$$16][$$7]  |PARTITIONED|
-                                                      exchange 
-                                                      -- HASH_PARTITION_EXCHANGE [$$16]  |PARTITIONED|
-                                                        project ([$$37, $$16, $$18])
-                                                        -- STREAM_PROJECT  |PARTITIONED|
-                                                          exchange 
-                                                          -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                                                            join (function-call: algebricks:eq, Args:[%0->$$18, %0->$$36])
-                                                            -- HYBRID_HASH_JOIN [$$18][$$36]  |PARTITIONED|
-                                                              exchange 
-                                                              -- HASH_PARTITION_EXCHANGE [$$18]  |PARTITIONED|
-                                                                project ([$$18, $$16])
-                                                                -- STREAM_PROJECT  |PARTITIONED|
-                                                                  select (function-call: algebricks:gt, Args:[%0->$$28, %0->$$27])
-                                                                  -- STREAM_SELECT  |PARTITIONED|
-                                                                    exchange 
-                                                                    -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                                                                      data-scan [$$16, $$18, $$27, $$28]<-[$$16, $$17, $$18, $$19, $$20, $$21, $$22, $$23, $$24, $$25, $$26, $$27, $$28, $$29, $$30, $$31] <- default.lineitem
-                                                                      -- DATASOURCE_SCAN  |PARTITIONED|
-                                                                        exchange 
-                                                                        -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                                                                          empty-tuple-source
-                                                                          -- EMPTY_TUPLE_SOURCE  |PARTITIONED|
-                                                              exchange 
-                                                              -- HASH_PARTITION_EXCHANGE [$$36]  |PARTITIONED|
-                                                                project ([$$36, $$37])
-                                                                -- STREAM_PROJECT  |PARTITIONED|
-                                                                  exchange 
-                                                                  -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                                                                    join (function-call: algebricks:eq, Args:[%0->$$39, %0->$$32])
-                                                                    -- HYBRID_HASH_JOIN [$$39][$$32]  |PARTITIONED|
-                                                                      exchange 
-                                                                      -- HASH_PARTITION_EXCHANGE [$$39]  |PARTITIONED|
-                                                                        data-scan [$$39, $$36, $$37]<-[$$36, $$37, $$38, $$39, $$40, $$41, $$42] <- default.supplier
-                                                                        -- DATASOURCE_SCAN  |PARTITIONED|
-                                                                          exchange 
-                                                                          -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                                                                            empty-tuple-source
-                                                                            -- EMPTY_TUPLE_SOURCE  |PARTITIONED|
-                                                                      exchange 
-                                                                      -- HASH_PARTITION_EXCHANGE [$$32]  |PARTITIONED|
-                                                                        project ([$$32])
-                                                                        -- STREAM_PROJECT  |PARTITIONED|
-                                                                          select (function-call: algebricks:eq, Args:[%0->$$33, SAUDI ARABIA])
-                                                                          -- STREAM_SELECT  |PARTITIONED|
-                                                                            exchange 
-                                                                            -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                                                                              data-scan [$$32, $$33]<-[$$32, $$33, $$34, $$35] <- default.nation
-                                                                              -- DATASOURCE_SCAN  |PARTITIONED|
-                                                                                exchange 
-                                                                                -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                                                                                  empty-tuple-source
-                                                                                  -- EMPTY_TUPLE_SOURCE  |PARTITIONED|
-                                                      exchange 
-                                                      -- HASH_PARTITION_EXCHANGE [$$7]  |PARTITIONED|
-                                                        project ([$$7])
-                                                        -- STREAM_PROJECT  |PARTITIONED|
-                                                          select (function-call: algebricks:eq, Args:[%0->$$9, F])
-                                                          -- STREAM_SELECT  |PARTITIONED|
-                                                            exchange 
-                                                            -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                                                              data-scan [$$7, $$9]<-[$$7, $$8, $$9, $$10, $$11, $$12, $$13, $$14, $$15] <- default.orders
-                                                              -- DATASOURCE_SCAN  |PARTITIONED|
-                                                                exchange 
-                                                                -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                                                                  empty-tuple-source
-                                                                  -- EMPTY_TUPLE_SOURCE  |PARTITIONED|
-                                              exchange 
-                                              -- HASH_PARTITION_EXCHANGE [$$4]  |PARTITIONED|
-                                                data-scan [$$4, $$5, $$6]<-[$$4, $$5, $$6] <- default.q21_tmp1
-                                                -- DATASOURCE_SCAN  |PARTITIONED|
-                                                  exchange 
-                                                  -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                                                    empty-tuple-source
-                                                    -- EMPTY_TUPLE_SOURCE  |PARTITIONED|
-                                    exchange 
-                                    -- HASH_PARTITION_EXCHANGE [$$1]  |PARTITIONED|
-                                      data-scan [$$1, $$2, $$3]<-[$$1, $$2, $$3] <- default.q21_tmp2
-                                      -- DATASOURCE_SCAN  |PARTITIONED|
-                                        exchange 
-                                        -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                                          empty-tuple-source
-                                          -- EMPTY_TUPLE_SOURCE  |PARTITIONED|

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/ffc967fd/hivesterix/hivesterix-dist/src/test/resources/optimizerts/results/q22_global_sales_opportunity.plan
----------------------------------------------------------------------
diff --git a/hivesterix/hivesterix-dist/src/test/resources/optimizerts/results/q22_global_sales_opportunity.plan b/hivesterix/hivesterix-dist/src/test/resources/optimizerts/results/q22_global_sales_opportunity.plan
deleted file mode 100644
index 15208bd..0000000
--- a/hivesterix/hivesterix-dist/src/test/resources/optimizerts/results/q22_global_sales_opportunity.plan
+++ /dev/null
@@ -1,132 +0,0 @@
-write [%0->$$6, %0->$$1, %0->$$9]
--- SINK_WRITE  |PARTITIONED|
-  project ([$$6, $$1, $$9])
-  -- STREAM_PROJECT  |PARTITIONED|
-    assign [$$9] <- [function-call: hive:org.apache.hadoop.hive.ql.udf.UDFSubstr, Args:[%0->$$5, 1, 2]]
-    -- ASSIGN  |PARTITIONED|
-      select (function-call: algebricks:or, Args:[function-call: algebricks:or, Args:[function-call: algebricks:or, Args:[function-call: algebricks:or, Args:[function-call: algebricks:or, Args:[function-call: algebricks:or, Args:[function-call: algebricks:eq, Args:[function-call: hive:org.apache.hadoop.hive.ql.udf.UDFSubstr, Args:[%0->$$5, 1, 2], 13], function-call: algebricks:eq, Args:[function-call: hive:org.apache.hadoop.hive.ql.udf.UDFSubstr, Args:[%0->$$5, 1, 2], 31]], function-call: algebricks:eq, Args:[function-call: hive:org.apache.hadoop.hive.ql.udf.UDFSubstr, Args:[%0->$$5, 1, 2], 23]], function-call: algebricks:eq, Args:[function-call: hive:org.apache.hadoop.hive.ql.udf.UDFSubstr, Args:[%0->$$5, 1, 2], 29]], function-call: algebricks:eq, Args:[function-call: hive:org.apache.hadoop.hive.ql.udf.UDFSubstr, Args:[%0->$$5, 1, 2], 30]], function-call: algebricks:eq, Args:[function-call: hive:org.apache.hadoop.hive.ql.udf.UDFSubstr, Args:[%0->$$5, 1, 2], 18]], function-call: alg
 ebricks:eq, Args:[function-call: hive:org.apache.hadoop.hive.ql.udf.UDFSubstr, Args:[%0->$$5, 1, 2], 17]])
-      -- STREAM_SELECT  |PARTITIONED|
-        exchange 
-        -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-          data-scan []<-[$$1, $$2, $$3, $$4, $$5, $$6, $$7, $$8] <- default.customer
-          -- DATASOURCE_SCAN  |PARTITIONED|
-            exchange 
-            -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-              empty-tuple-source
-              -- EMPTY_TUPLE_SOURCE  |PARTITIONED|
-write [%0->$$4]
--- SINK_WRITE  |PARTITIONED|
-  exchange 
-  -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-    group by ([]) decor ([]) {
-              aggregate [$$4] <- [function-call: hive:avg(FINAL), Args:[%0->$$6]]
-              -- AGGREGATE  |LOCAL|
-                nested tuple source
-                -- NESTED_TUPLE_SOURCE  |LOCAL|
-           }
-    -- PRE_CLUSTERED_GROUP_BY[]  |PARTITIONED|
-      exchange 
-      -- HASH_PARTITION_EXCHANGE []  |PARTITIONED|
-        group by ([]) decor ([]) {
-                  aggregate [$$6] <- [function-call: hive:avg(PARTIAL1), Args:[%0->$$1]]
-                  -- AGGREGATE  |LOCAL|
-                    nested tuple source
-                    -- NESTED_TUPLE_SOURCE  |LOCAL|
-               }
-        -- PRE_CLUSTERED_GROUP_BY[]  |PARTITIONED|
-          exchange 
-          -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-            select (function-call: algebricks:gt, Args:[%0->$$1, 0.0])
-            -- STREAM_SELECT  |PARTITIONED|
-              exchange 
-              -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                data-scan [$$1]<-[$$1, $$2, $$3] <- default.q22_customer_tmp
-                -- DATASOURCE_SCAN  |PARTITIONED|
-                  exchange 
-                  -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                    empty-tuple-source
-                    -- EMPTY_TUPLE_SOURCE  |PARTITIONED|
-write [%0->$$2]
--- SINK_WRITE  |PARTITIONED|
-  exchange 
-  -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-    distinct ([%0->$$2])
-    -- PRE_SORTED_DISTINCT_BY  |PARTITIONED|
-      exchange 
-      -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-        order (ASC, %0->$$2) 
-        -- STABLE_SORT [$$2(ASC)]  |PARTITIONED|
-          exchange 
-          -- HASH_PARTITION_EXCHANGE [$$2]  |PARTITIONED|
-            data-scan [$$2]<-[$$1, $$2, $$3, $$4, $$5, $$6, $$7, $$8, $$9] <- default.orders
-            -- DATASOURCE_SCAN  |PARTITIONED|
-              exchange 
-              -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                empty-tuple-source
-                -- EMPTY_TUPLE_SOURCE  |PARTITIONED|
-write [%0->$$6, %0->$$9, %0->$$8]
--- SINK_WRITE  |PARTITIONED|
-  project ([$$6, $$9, $$8])
-  -- STREAM_PROJECT  |PARTITIONED|
-    assign [$$9] <- [function-call: hive:org.apache.hadoop.hive.ql.udf.UDFToInteger, Args:[%0->$$7]]
-    -- ASSIGN  |PARTITIONED|
-      exchange 
-      -- SORT_MERGE_EXCHANGE [$$6(ASC) ]  |PARTITIONED|
-        group by ([$$6 := %0->$$13]) decor ([]) {
-                  aggregate [$$7, $$8] <- [function-call: hive:count(FINAL), Args:[%0->$$11], function-call: hive:sum(FINAL), Args:[%0->$$12]]
-                  -- AGGREGATE  |LOCAL|
-                    nested tuple source
-                    -- NESTED_TUPLE_SOURCE  |LOCAL|
-               }
-        -- PRE_CLUSTERED_GROUP_BY[$$13]  |PARTITIONED|
-          exchange 
-          -- HASH_PARTITION_MERGE_EXCHANGE MERGE:[$$13(ASC)] HASH:[$$13]  |PARTITIONED|
-            group by ([$$13 := %0->$$5]) decor ([]) {
-                      aggregate [$$11, $$12] <- [function-call: hive:count(PARTIAL1), Args:[1], function-call: hive:sum(PARTIAL1), Args:[%0->$$3]]
-                      -- AGGREGATE  |LOCAL|
-                        nested tuple source
-                        -- NESTED_TUPLE_SOURCE  |LOCAL|
-                   }
-            -- SORT_GROUP_BY[$$5]  |PARTITIONED|
-              exchange 
-              -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                project ([$$5, $$3])
-                -- STREAM_PROJECT  |PARTITIONED|
-                  exchange 
-                  -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                    join (function-call: algebricks:and, Args:[function-call: algebricks:gt, Args:[%0->$$3, %0->$$1], true])
-                    -- NESTED_LOOP  |PARTITIONED|
-                      exchange 
-                      -- BROADCAST_EXCHANGE  |PARTITIONED|
-                        project ([$$5, $$3])
-                        -- STREAM_PROJECT  |PARTITIONED|
-                          select (function-call: hive:org.apache.hadoop.hive.ql.udf.generic.GenericUDFOPNull, Args:[%0->$$2])
-                          -- STREAM_SELECT  |PARTITIONED|
-                            exchange 
-                            -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                              left outer join (function-call: algebricks:eq, Args:[%0->$$4, %0->$$2])
-                              -- HYBRID_HASH_JOIN [$$4][$$2]  |PARTITIONED|
-                                exchange 
-                                -- HASH_PARTITION_EXCHANGE [$$4]  |PARTITIONED|
-                                  data-scan []<-[$$3, $$4, $$5] <- default.q22_customer_tmp
-                                  -- DATASOURCE_SCAN  |PARTITIONED|
-                                    exchange 
-                                    -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                                      empty-tuple-source
-                                      -- EMPTY_TUPLE_SOURCE  |PARTITIONED|
-                                exchange 
-                                -- HASH_PARTITION_EXCHANGE [$$2]  |PARTITIONED|
-                                  data-scan [$$2]<-[$$2] <- default.q22_orders_tmp
-                                  -- DATASOURCE_SCAN  |PARTITIONED|
-                                    exchange 
-                                    -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                                      empty-tuple-source
-                                      -- EMPTY_TUPLE_SOURCE  |PARTITIONED|
-                      exchange 
-                      -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                        data-scan [$$1]<-[$$1] <- default.q22_customer_tmp1
-                        -- DATASOURCE_SCAN  |PARTITIONED|
-                          exchange 
-                          -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                            empty-tuple-source
-                            -- EMPTY_TUPLE_SOURCE  |PARTITIONED|

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/ffc967fd/hivesterix/hivesterix-dist/src/test/resources/optimizerts/results/q2_minimum_cost_supplier.plan
----------------------------------------------------------------------
diff --git a/hivesterix/hivesterix-dist/src/test/resources/optimizerts/results/q2_minimum_cost_supplier.plan b/hivesterix/hivesterix-dist/src/test/resources/optimizerts/results/q2_minimum_cost_supplier.plan
deleted file mode 100644
index 2714806..0000000
--- a/hivesterix/hivesterix-dist/src/test/resources/optimizerts/results/q2_minimum_cost_supplier.plan
+++ /dev/null
@@ -1,152 +0,0 @@
-write [%0->$$20, %0->$$16, %0->$$26, %0->$$1, %0->$$13, %0->$$3, %0->$$17, %0->$$19, %0->$$21]
--- SINK_WRITE  |PARTITIONED|
-  project ([$$20, $$16, $$26, $$1, $$13, $$3, $$17, $$19, $$21])
-  -- STREAM_PROJECT  |PARTITIONED|
-    exchange 
-    -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-      join (function-call: algebricks:eq, Args:[%0->$$1, %0->$$10])
-      -- HYBRID_HASH_JOIN [$$1][$$10]  |PARTITIONED|
-        exchange 
-        -- HASH_PARTITION_EXCHANGE [$$1]  |PARTITIONED|
-          project ([$$1, $$3])
-          -- STREAM_PROJECT  |PARTITIONED|
-            select (function-call: algebricks:and, Args:[function-call: algebricks:eq, Args:[%0->$$6, 15], function-call: hive:org.apache.hadoop.hive.ql.udf.UDFLike, Args:[%0->$$5, %BRASS]])
-            -- STREAM_SELECT  |PARTITIONED|
-              exchange 
-              -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                data-scan [$$1, $$3, $$5, $$6]<-[$$1, $$2, $$3, $$4, $$5, $$6, $$7, $$8, $$9] <- default.part
-                -- DATASOURCE_SCAN  |PARTITIONED|
-                  exchange 
-                  -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                    empty-tuple-source
-                    -- EMPTY_TUPLE_SOURCE  |PARTITIONED|
-        exchange 
-        -- HASH_PARTITION_EXCHANGE [$$10]  |PARTITIONED|
-          project ([$$10, $$16, $$17, $$19, $$20, $$21, $$26, $$13])
-          -- STREAM_PROJECT  |PARTITIONED|
-            exchange 
-            -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-              join (function-call: algebricks:eq, Args:[%0->$$11, %0->$$15])
-              -- HYBRID_HASH_JOIN [$$11][$$15]  |PARTITIONED|
-                exchange 
-                -- HASH_PARTITION_EXCHANGE [$$11]  |PARTITIONED|
-                  data-scan [$$11, $$10, $$13]<-[$$10, $$11, $$12, $$13, $$14] <- default.partsupp
-                  -- DATASOURCE_SCAN  |PARTITIONED|
-                    exchange 
-                    -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                      empty-tuple-source
-                      -- EMPTY_TUPLE_SOURCE  |PARTITIONED|
-                exchange 
-                -- HASH_PARTITION_EXCHANGE [$$15]  |PARTITIONED|
-                  project ([$$15, $$16, $$17, $$19, $$20, $$21, $$26])
-                  -- STREAM_PROJECT  |PARTITIONED|
-                    exchange 
-                    -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                      join (function-call: algebricks:eq, Args:[%0->$$18, %0->$$25])
-                      -- HYBRID_HASH_JOIN [$$18][$$25]  |PARTITIONED|
-                        exchange 
-                        -- HASH_PARTITION_EXCHANGE [$$18]  |PARTITIONED|
-                          data-scan []<-[$$15, $$16, $$17, $$18, $$19, $$20, $$21] <- default.supplier
-                          -- DATASOURCE_SCAN  |PARTITIONED|
-                            exchange 
-                            -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                              empty-tuple-source
-                              -- EMPTY_TUPLE_SOURCE  |PARTITIONED|
-                        exchange 
-                        -- HASH_PARTITION_EXCHANGE [$$25]  |PARTITIONED|
-                          project ([$$25, $$26])
-                          -- STREAM_PROJECT  |PARTITIONED|
-                            exchange 
-                            -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                              join (function-call: algebricks:eq, Args:[%0->$$22, %0->$$27])
-                              -- HYBRID_HASH_JOIN [$$22][$$27]  |PARTITIONED|
-                                exchange 
-                                -- HASH_PARTITION_EXCHANGE [$$22]  |PARTITIONED|
-                                  project ([$$22])
-                                  -- STREAM_PROJECT  |PARTITIONED|
-                                    select (function-call: algebricks:eq, Args:[%0->$$23, EUROPE])
-                                    -- STREAM_SELECT  |PARTITIONED|
-                                      exchange 
-                                      -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                                        data-scan [$$23, $$22]<-[$$22, $$23, $$24] <- default.region
-                                        -- DATASOURCE_SCAN  |PARTITIONED|
-                                          exchange 
-                                          -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                                            empty-tuple-source
-                                            -- EMPTY_TUPLE_SOURCE  |PARTITIONED|
-                                exchange 
-                                -- HASH_PARTITION_EXCHANGE [$$27]  |PARTITIONED|
-                                  data-scan [$$27, $$25, $$26]<-[$$25, $$26, $$27, $$28] <- default.nation
-                                  -- DATASOURCE_SCAN  |PARTITIONED|
-                                    exchange 
-                                    -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                                      empty-tuple-source
-                                      -- EMPTY_TUPLE_SOURCE  |PARTITIONED|
-write [%0->$$10, %0->$$11]
--- SINK_WRITE  |PARTITIONED|
-  project ([$$10, $$11])
-  -- STREAM_PROJECT  |PARTITIONED|
-    exchange 
-    -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-      group by ([$$10 := %0->$$14]) decor ([]) {
-                aggregate [$$11] <- [function-call: hive:min(FINAL), Args:[%0->$$13]]
-                -- AGGREGATE  |LOCAL|
-                  nested tuple source
-                  -- NESTED_TUPLE_SOURCE  |LOCAL|
-             }
-      -- PRE_CLUSTERED_GROUP_BY[$$14]  |PARTITIONED|
-        exchange 
-        -- HASH_PARTITION_MERGE_EXCHANGE MERGE:[$$14(ASC)] HASH:[$$14]  |PARTITIONED|
-          group by ([$$14 := %0->$$4]) decor ([]) {
-                    aggregate [$$13] <- [function-call: hive:min(PARTIAL1), Args:[%0->$$5]]
-                    -- AGGREGATE  |LOCAL|
-                      nested tuple source
-                      -- NESTED_TUPLE_SOURCE  |LOCAL|
-                 }
-          -- SORT_GROUP_BY[$$4]  |PARTITIONED|
-            exchange 
-            -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-              data-scan [$$4, $$5]<-[$$1, $$2, $$3, $$4, $$5, $$6, $$7, $$8, $$9] <- default.q2_minimum_cost_supplier_tmp1
-              -- DATASOURCE_SCAN  |PARTITIONED|
-                exchange 
-                -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                  empty-tuple-source
-                  -- EMPTY_TUPLE_SOURCE  |PARTITIONED|
-write [%0->$$3, %0->$$4, %0->$$5, %0->$$6, %0->$$8, %0->$$9, %0->$$10, %0->$$11]
--- SINK_WRITE  |UNPARTITIONED|
-  limit 100
-  -- STREAM_LIMIT  |UNPARTITIONED|
-    limit 100
-    -- STREAM_LIMIT  |UNPARTITIONED|
-      exchange 
-      -- SORT_MERGE_EXCHANGE [$$3(DESC), $$5(ASC), $$4(ASC), $$6(ASC) ]  |PARTITIONED|
-        limit 100
-        -- STREAM_LIMIT  |PARTITIONED|
-          exchange 
-          -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-            order (DESC, %0->$$3) (ASC, %0->$$5) (ASC, %0->$$4) (ASC, %0->$$6) 
-            -- STABLE_SORT [$$3(DESC), $$5(ASC), $$4(ASC), $$6(ASC)]  |PARTITIONED|
-              exchange 
-              -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                project ([$$3, $$4, $$5, $$6, $$8, $$9, $$10, $$11])
-                -- STREAM_PROJECT  |PARTITIONED|
-                  exchange 
-                  -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                    join (function-call: algebricks:and, Args:[function-call: algebricks:eq, Args:[%0->$$1, %0->$$6], function-call: algebricks:eq, Args:[%0->$$2, %0->$$7]])
-                    -- HYBRID_HASH_JOIN [$$1, $$2][$$6, $$7]  |PARTITIONED|
-                      exchange 
-                      -- HASH_PARTITION_EXCHANGE [$$1, $$2]  |PARTITIONED|
-                        data-scan []<-[$$1, $$2] <- default.q2_minimum_cost_supplier_tmp2
-                        -- DATASOURCE_SCAN  |PARTITIONED|
-                          exchange 
-                          -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                            empty-tuple-source
-                            -- EMPTY_TUPLE_SOURCE  |PARTITIONED|
-                      exchange 
-                      -- HASH_PARTITION_EXCHANGE [$$6, $$7]  |PARTITIONED|
-                        data-scan [$$6, $$7, $$3, $$4, $$5, $$8, $$9, $$10, $$11]<-[$$3, $$4, $$5, $$6, $$7, $$8, $$9, $$10, $$11] <- default.q2_minimum_cost_supplier_tmp1
-                        -- DATASOURCE_SCAN  |PARTITIONED|
-                          exchange 
-                          -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                            empty-tuple-source
-                            -- EMPTY_TUPLE_SOURCE  |PARTITIONED|

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/ffc967fd/hivesterix/hivesterix-dist/src/test/resources/optimizerts/results/q3_shipping_priority.plan
----------------------------------------------------------------------
diff --git a/hivesterix/hivesterix-dist/src/test/resources/optimizerts/results/q3_shipping_priority.plan b/hivesterix/hivesterix-dist/src/test/resources/optimizerts/results/q3_shipping_priority.plan
deleted file mode 100644
index 05563e2..0000000
--- a/hivesterix/hivesterix-dist/src/test/resources/optimizerts/results/q3_shipping_priority.plan
+++ /dev/null
@@ -1,70 +0,0 @@
-write [%0->$$1, %0->$$34, %0->$$29, %0->$$32]
--- SINK_WRITE  |UNPARTITIONED|
-  limit 10
-  -- STREAM_LIMIT  |UNPARTITIONED|
-    limit 10
-    -- STREAM_LIMIT  |UNPARTITIONED|
-      exchange 
-      -- SORT_MERGE_EXCHANGE [$$34(DESC) ]  |PARTITIONED|
-        limit 10
-        -- STREAM_LIMIT  |PARTITIONED|
-          exchange 
-          -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-            order (DESC, %0->$$34) 
-            -- STABLE_SORT [$$34(DESC)]  |PARTITIONED|
-              exchange 
-              -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                project ([$$1, $$34, $$29, $$32])
-                -- STREAM_PROJECT  |PARTITIONED|
-                  assign [$$34] <- [function-call: hive:org.apache.hadoop.hive.ql.udf.UDFOPMultiply, Args:[%0->$$6, function-call: hive:org.apache.hadoop.hive.ql.udf.UDFOPMinus, Args:[1, %0->$$7]]]
-                  -- ASSIGN  |PARTITIONED|
-                    project ([$$29, $$32, $$1, $$6, $$7])
-                    -- STREAM_PROJECT  |PARTITIONED|
-                      exchange 
-                      -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                        join (function-call: algebricks:eq, Args:[%0->$$1, %0->$$25])
-                        -- HYBRID_HASH_JOIN [$$1][$$25]  |PARTITIONED|
-                          exchange 
-                          -- HASH_PARTITION_EXCHANGE [$$1]  |PARTITIONED|
-                            project ([$$1, $$6, $$7])
-                            -- STREAM_PROJECT  |PARTITIONED|
-                              select (function-call: algebricks:lt, Args:[%0->$$4, 3])
-                              -- STREAM_SELECT  |PARTITIONED|
-                                exchange 
-                                -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                                  data-scan [$$1, $$4, $$6, $$7]<-[$$1, $$2, $$3, $$4, $$5, $$6, $$7, $$8, $$9, $$10, $$11, $$12, $$13, $$14, $$15, $$16] <- default.lineitem
-                                  -- DATASOURCE_SCAN  |PARTITIONED|
-                                    exchange 
-                                    -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                                      empty-tuple-source
-                                      -- EMPTY_TUPLE_SOURCE  |PARTITIONED|
-                          exchange 
-                          -- HASH_PARTITION_EXCHANGE [$$25]  |PARTITIONED|
-                            project ([$$25, $$29, $$32])
-                            -- STREAM_PROJECT  |PARTITIONED|
-                              exchange 
-                              -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                                join (function-call: algebricks:eq, Args:[%0->$$26, %0->$$17])
-                                -- HYBRID_HASH_JOIN [$$26][$$17]  |PARTITIONED|
-                                  exchange 
-                                  -- HASH_PARTITION_EXCHANGE [$$26]  |PARTITIONED|
-                                    data-scan [$$26, $$25, $$29, $$32]<-[$$25, $$26, $$27, $$28, $$29, $$30, $$31, $$32, $$33] <- default.orders
-                                    -- DATASOURCE_SCAN  |PARTITIONED|
-                                      exchange 
-                                      -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                                        empty-tuple-source
-                                        -- EMPTY_TUPLE_SOURCE  |PARTITIONED|
-                                  exchange 
-                                  -- HASH_PARTITION_EXCHANGE [$$17]  |PARTITIONED|
-                                    project ([$$17])
-                                    -- STREAM_PROJECT  |PARTITIONED|
-                                      select (function-call: algebricks:eq, Args:[%0->$$23, BUILDING])
-                                      -- STREAM_SELECT  |PARTITIONED|
-                                        exchange 
-                                        -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                                          data-scan [$$17, $$23]<-[$$17, $$18, $$19, $$20, $$21, $$22, $$23, $$24] <- default.customer
-                                          -- DATASOURCE_SCAN  |PARTITIONED|
-                                            exchange 
-                                            -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                                              empty-tuple-source
-                                              -- EMPTY_TUPLE_SOURCE  |PARTITIONED|

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/ffc967fd/hivesterix/hivesterix-dist/src/test/resources/optimizerts/results/q4_order_priority.plan
----------------------------------------------------------------------
diff --git a/hivesterix/hivesterix-dist/src/test/resources/optimizerts/results/q4_order_priority.plan b/hivesterix/hivesterix-dist/src/test/resources/optimizerts/results/q4_order_priority.plan
deleted file mode 100644
index 23a64fe..0000000
--- a/hivesterix/hivesterix-dist/src/test/resources/optimizerts/results/q4_order_priority.plan
+++ /dev/null
@@ -1,78 +0,0 @@
-write [%0->$$1]
--- SINK_WRITE  |PARTITIONED|
-  exchange 
-  -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-    distinct ([%0->$$1])
-    -- PRE_SORTED_DISTINCT_BY  |PARTITIONED|
-      exchange 
-      -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-        order (ASC, %0->$$1) 
-        -- STABLE_SORT [$$1(ASC)]  |PARTITIONED|
-          exchange 
-          -- HASH_PARTITION_EXCHANGE [$$1]  |PARTITIONED|
-            project ([$$1])
-            -- STREAM_PROJECT  |PARTITIONED|
-              select (function-call: algebricks:lt, Args:[%0->$$12, %0->$$13])
-              -- STREAM_SELECT  |PARTITIONED|
-                exchange 
-                -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                  data-scan [$$1, $$12, $$13]<-[$$1, $$2, $$3, $$4, $$5, $$6, $$7, $$8, $$9, $$10, $$11, $$12, $$13, $$14, $$15, $$16] <- default.lineitem
-                  -- DATASOURCE_SCAN  |PARTITIONED|
-                    exchange 
-                    -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                      empty-tuple-source
-                      -- EMPTY_TUPLE_SOURCE  |PARTITIONED|
-write [%0->$$11, %0->$$13]
--- SINK_WRITE  |PARTITIONED|
-  project ([$$11, $$13])
-  -- STREAM_PROJECT  |PARTITIONED|
-    assign [$$13] <- [function-call: hive:org.apache.hadoop.hive.ql.udf.UDFToInteger, Args:[%0->$$12]]
-    -- ASSIGN  |PARTITIONED|
-      exchange 
-      -- SORT_MERGE_EXCHANGE [$$11(ASC) ]  |PARTITIONED|
-        group by ([$$11 := %0->$$16]) decor ([]) {
-                  aggregate [$$12] <- [function-call: hive:count(FINAL), Args:[%0->$$15]]
-                  -- AGGREGATE  |LOCAL|
-                    nested tuple source
-                    -- NESTED_TUPLE_SOURCE  |LOCAL|
-               }
-        -- PRE_CLUSTERED_GROUP_BY[$$16]  |PARTITIONED|
-          exchange 
-          -- HASH_PARTITION_MERGE_EXCHANGE MERGE:[$$16(ASC)] HASH:[$$16]  |PARTITIONED|
-            group by ([$$16 := %0->$$7]) decor ([]) {
-                      aggregate [$$15] <- [function-call: hive:count(PARTIAL1), Args:[1]]
-                      -- AGGREGATE  |LOCAL|
-                        nested tuple source
-                        -- NESTED_TUPLE_SOURCE  |LOCAL|
-                   }
-            -- SORT_GROUP_BY[$$7]  |PARTITIONED|
-              exchange 
-              -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                project ([$$7])
-                -- STREAM_PROJECT  |PARTITIONED|
-                  exchange 
-                  -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                    join (function-call: algebricks:eq, Args:[%0->$$1, %0->$$2])
-                    -- HYBRID_HASH_JOIN [$$1][$$2]  |PARTITIONED|
-                      exchange 
-                      -- HASH_PARTITION_EXCHANGE [$$1]  |PARTITIONED|
-                        data-scan []<-[$$1] <- default.q4_order_priority_tmp
-                        -- DATASOURCE_SCAN  |PARTITIONED|
-                          exchange 
-                          -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                            empty-tuple-source
-                            -- EMPTY_TUPLE_SOURCE  |PARTITIONED|
-                      exchange 
-                      -- HASH_PARTITION_EXCHANGE [$$2]  |PARTITIONED|
-                        project ([$$2, $$7])
-                        -- STREAM_PROJECT  |PARTITIONED|
-                          select (function-call: algebricks:and, Args:[function-call: algebricks:ge, Args:[%0->$$6, 1993-07-01], function-call: algebricks:lt, Args:[%0->$$6, 1993-10-01]])
-                          -- STREAM_SELECT  |PARTITIONED|
-                            exchange 
-                            -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                              data-scan [$$2, $$6, $$7]<-[$$2, $$3, $$4, $$5, $$6, $$7, $$8, $$9, $$10] <- default.orders
-                              -- DATASOURCE_SCAN  |PARTITIONED|
-                                exchange 
-                                -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                                  empty-tuple-source
-                                  -- EMPTY_TUPLE_SOURCE  |PARTITIONED|

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/ffc967fd/hivesterix/hivesterix-dist/src/test/resources/optimizerts/results/q5_local_supplier_volume.plan
----------------------------------------------------------------------
diff --git a/hivesterix/hivesterix-dist/src/test/resources/optimizerts/results/q5_local_supplier_volume.plan b/hivesterix/hivesterix-dist/src/test/resources/optimizerts/results/q5_local_supplier_volume.plan
deleted file mode 100644
index a0f5b8c..0000000
--- a/hivesterix/hivesterix-dist/src/test/resources/optimizerts/results/q5_local_supplier_volume.plan
+++ /dev/null
@@ -1,126 +0,0 @@
-write [%0->$$48, %0->$$49]
--- SINK_WRITE  |PARTITIONED|
-  project ([$$48, $$49])
-  -- STREAM_PROJECT  |PARTITIONED|
-    exchange 
-    -- SORT_MERGE_EXCHANGE [$$49(DESC) ]  |PARTITIONED|
-      order (DESC, %0->$$49) 
-      -- STABLE_SORT [$$49(DESC)]  |PARTITIONED|
-        exchange 
-        -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-          group by ([$$48 := %0->$$52]) decor ([]) {
-                    aggregate [$$49] <- [function-call: hive:sum(FINAL), Args:[%0->$$51]]
-                    -- AGGREGATE  |LOCAL|
-                      nested tuple source
-                      -- NESTED_TUPLE_SOURCE  |LOCAL|
-                 }
-          -- PRE_CLUSTERED_GROUP_BY[$$52]  |PARTITIONED|
-            exchange 
-            -- HASH_PARTITION_MERGE_EXCHANGE MERGE:[$$52(ASC)] HASH:[$$52]  |PARTITIONED|
-              group by ([$$52 := %0->$$42]) decor ([]) {
-                        aggregate [$$51] <- [function-call: hive:sum(PARTIAL1), Args:[function-call: hive:org.apache.hadoop.hive.ql.udf.UDFOPMultiply, Args:[%0->$$23, function-call: hive:org.apache.hadoop.hive.ql.udf.UDFOPMinus, Args:[1, %0->$$24]]]]
-                        -- AGGREGATE  |LOCAL|
-                          nested tuple source
-                          -- NESTED_TUPLE_SOURCE  |LOCAL|
-                     }
-              -- SORT_GROUP_BY[$$42]  |PARTITIONED|
-                exchange 
-                -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                  project ([$$42, $$23, $$24])
-                  -- STREAM_PROJECT  |PARTITIONED|
-                    exchange 
-                    -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                      join (function-call: algebricks:and, Args:[function-call: algebricks:eq, Args:[%0->$$37, %0->$$4], function-call: algebricks:eq, Args:[%0->$$10, %0->$$1]])
-                      -- HYBRID_HASH_JOIN [$$37, $$10][$$4, $$1]  |PARTITIONED|
-                        exchange 
-                        -- HASH_PARTITION_EXCHANGE [$$37, $$10]  |PARTITIONED|
-                          project ([$$10, $$42, $$23, $$24, $$37])
-                          -- STREAM_PROJECT  |PARTITIONED|
-                            exchange 
-                            -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                              join (function-call: algebricks:eq, Args:[%0->$$18, %0->$$9])
-                              -- HYBRID_HASH_JOIN [$$18][$$9]  |PARTITIONED|
-                                exchange 
-                                -- HASH_PARTITION_EXCHANGE [$$18]  |PARTITIONED|
-                                  project ([$$18, $$23, $$24, $$42, $$37])
-                                  -- STREAM_PROJECT  |PARTITIONED|
-                                    exchange 
-                                    -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                                      join (function-call: algebricks:eq, Args:[%0->$$34, %0->$$20])
-                                      -- HYBRID_HASH_JOIN [$$34][$$20]  |PARTITIONED|
-                                        exchange 
-                                        -- HASH_PARTITION_EXCHANGE [$$34]  |PARTITIONED|
-                                          project ([$$34, $$37, $$42])
-                                          -- STREAM_PROJECT  |PARTITIONED|
-                                            exchange 
-                                            -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                                              join (function-call: algebricks:eq, Args:[%0->$$41, %0->$$37])
-                                              -- HYBRID_HASH_JOIN [$$41][$$37]  |PARTITIONED|
-                                                exchange 
-                                                -- HASH_PARTITION_EXCHANGE [$$41]  |PARTITIONED|
-                                                  project ([$$41, $$42])
-                                                  -- STREAM_PROJECT  |PARTITIONED|
-                                                    exchange 
-                                                    -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                                                      join (function-call: algebricks:eq, Args:[%0->$$45, %0->$$43])
-                                                      -- HYBRID_HASH_JOIN [$$45][$$43]  |PARTITIONED|
-                                                        exchange 
-                                                        -- HASH_PARTITION_EXCHANGE [$$45]  |PARTITIONED|
-                                                          project ([$$45])
-                                                          -- STREAM_PROJECT  |PARTITIONED|
-                                                            select (function-call: algebricks:eq, Args:[%0->$$46, ASIA])
-                                                            -- STREAM_SELECT  |PARTITIONED|
-                                                              exchange 
-                                                              -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                                                                data-scan [$$46, $$45]<-[$$45, $$46, $$47] <- default.region
-                                                                -- DATASOURCE_SCAN  |PARTITIONED|
-                                                                  exchange 
-                                                                  -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                                                                    empty-tuple-source
-                                                                    -- EMPTY_TUPLE_SOURCE  |PARTITIONED|
-                                                        exchange 
-                                                        -- HASH_PARTITION_EXCHANGE [$$43]  |PARTITIONED|
-                                                          data-scan [$$43, $$41, $$42]<-[$$41, $$42, $$43, $$44] <- default.nation
-                                                          -- DATASOURCE_SCAN  |PARTITIONED|
-                                                            exchange 
-                                                            -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                                                              empty-tuple-source
-                                                              -- EMPTY_TUPLE_SOURCE  |PARTITIONED|
-                                                exchange 
-                                                -- HASH_PARTITION_EXCHANGE [$$37]  |PARTITIONED|
-                                                  data-scan [$$37, $$34]<-[$$34, $$35, $$36, $$37, $$38, $$39, $$40] <- default.supplier
-                                                  -- DATASOURCE_SCAN  |PARTITIONED|
-                                                    exchange 
-                                                    -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                                                      empty-tuple-source
-                                                      -- EMPTY_TUPLE_SOURCE  |PARTITIONED|
-                                        exchange 
-                                        -- HASH_PARTITION_EXCHANGE [$$20]  |PARTITIONED|
-                                          data-scan [$$20, $$18, $$23, $$24]<-[$$18, $$19, $$20, $$21, $$22, $$23, $$24, $$25, $$26, $$27, $$28, $$29, $$30, $$31, $$32, $$33] <- default.lineitem
-                                          -- DATASOURCE_SCAN  |PARTITIONED|
-                                            exchange 
-                                            -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                                              empty-tuple-source
-                                              -- EMPTY_TUPLE_SOURCE  |PARTITIONED|
-                                exchange 
-                                -- HASH_PARTITION_EXCHANGE [$$9]  |PARTITIONED|
-                                  project ([$$9, $$10])
-                                  -- STREAM_PROJECT  |PARTITIONED|
-                                    select (function-call: algebricks:and, Args:[function-call: algebricks:ge, Args:[%0->$$13, 1994-01-01], function-call: algebricks:lt, Args:[%0->$$13, 1995-01-01]])
-                                    -- STREAM_SELECT  |PARTITIONED|
-                                      exchange 
-                                      -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                                        data-scan [$$9, $$10, $$13]<-[$$9, $$10, $$11, $$12, $$13, $$14, $$15, $$16, $$17] <- default.orders
-                                        -- DATASOURCE_SCAN  |PARTITIONED|
-                                          exchange 
-                                          -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                                            empty-tuple-source
-                                            -- EMPTY_TUPLE_SOURCE  |PARTITIONED|
-                        exchange 
-                        -- HASH_PARTITION_EXCHANGE [$$4, $$1]  |PARTITIONED|
-                          data-scan [$$4, $$1]<-[$$1, $$2, $$3, $$4, $$5, $$6, $$7, $$8] <- default.customer
-                          -- DATASOURCE_SCAN  |PARTITIONED|
-                            exchange 
-                            -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                              empty-tuple-source
-                              -- EMPTY_TUPLE_SOURCE  |PARTITIONED|

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/ffc967fd/hivesterix/hivesterix-dist/src/test/resources/optimizerts/results/q6_forecast_revenue_change.plan
----------------------------------------------------------------------
diff --git a/hivesterix/hivesterix-dist/src/test/resources/optimizerts/results/q6_forecast_revenue_change.plan b/hivesterix/hivesterix-dist/src/test/resources/optimizerts/results/q6_forecast_revenue_change.plan
deleted file mode 100644
index 03363f3..0000000
--- a/hivesterix/hivesterix-dist/src/test/resources/optimizerts/results/q6_forecast_revenue_change.plan
+++ /dev/null
@@ -1,34 +0,0 @@
-write [%0->$$17]
--- SINK_WRITE  |PARTITIONED|
-  exchange 
-  -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-    group by ([]) decor ([]) {
-              aggregate [$$17] <- [function-call: hive:sum(FINAL), Args:[%0->$$19]]
-              -- AGGREGATE  |LOCAL|
-                nested tuple source
-                -- NESTED_TUPLE_SOURCE  |LOCAL|
-           }
-    -- PRE_CLUSTERED_GROUP_BY[]  |PARTITIONED|
-      exchange 
-      -- HASH_PARTITION_EXCHANGE []  |PARTITIONED|
-        group by ([]) decor ([]) {
-                  aggregate [$$19] <- [function-call: hive:sum(PARTIAL1), Args:[function-call: hive:org.apache.hadoop.hive.ql.udf.UDFOPMultiply, Args:[%0->$$6, %0->$$7]]]
-                  -- AGGREGATE  |LOCAL|
-                    nested tuple source
-                    -- NESTED_TUPLE_SOURCE  |LOCAL|
-               }
-        -- PRE_CLUSTERED_GROUP_BY[]  |PARTITIONED|
-          exchange 
-          -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-            project ([$$6, $$7])
-            -- STREAM_PROJECT  |PARTITIONED|
-              select (function-call: algebricks:and, Args:[function-call: algebricks:ge, Args:[%0->$$11, 1994-01-01], function-call: algebricks:lt, Args:[%0->$$11, 1995-01-01], function-call: algebricks:ge, Args:[%0->$$7, 0.05], function-call: algebricks:le, Args:[%0->$$7, 0.07], function-call: algebricks:lt, Args:[%0->$$5, 24.0]])
-              -- STREAM_SELECT  |PARTITIONED|
-                exchange 
-                -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                  data-scan [$$5, $$6, $$7, $$11]<-[$$1, $$2, $$3, $$4, $$5, $$6, $$7, $$8, $$9, $$10, $$11, $$12, $$13, $$14, $$15, $$16] <- default.lineitem
-                  -- DATASOURCE_SCAN  |PARTITIONED|
-                    exchange 
-                    -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                      empty-tuple-source
-                      -- EMPTY_TUPLE_SOURCE  |PARTITIONED|

http://git-wip-us.apache.org/repos/asf/incubator-asterixdb-hyracks/blob/ffc967fd/hivesterix/hivesterix-dist/src/test/resources/optimizerts/results/q7_volume_shipping.plan
----------------------------------------------------------------------
diff --git a/hivesterix/hivesterix-dist/src/test/resources/optimizerts/results/q7_volume_shipping.plan b/hivesterix/hivesterix-dist/src/test/resources/optimizerts/results/q7_volume_shipping.plan
deleted file mode 100644
index 70d8e7b..0000000
--- a/hivesterix/hivesterix-dist/src/test/resources/optimizerts/results/q7_volume_shipping.plan
+++ /dev/null
@@ -1,232 +0,0 @@
-write [%0->$$17, %0->$$18, %0->$$19, %0->$$20]
--- SINK_WRITE  |PARTITIONED|
-  exchange 
-  -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-    union ($$6, $$10, $$17) ($$2, $$14, $$18) ($$5, $$9, $$19) ($$1, $$13, $$20)
-    -- UNION_ALL  |PARTITIONED|
-      exchange 
-      -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-        project ([$$6, $$2, $$5, $$1])
-        -- STREAM_PROJECT  |PARTITIONED|
-          exchange 
-          -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-            join (true)
-            -- NESTED_LOOP  |PARTITIONED|
-              exchange 
-              -- BROADCAST_EXCHANGE  |PARTITIONED|
-                project ([$$1, $$2])
-                -- STREAM_PROJECT  |PARTITIONED|
-                  assign [$$1, $$2] <- [%0->$$9, %0->$$10]
-                  -- ASSIGN  |PARTITIONED|
-                    exchange 
-                    -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                      replicate 
-                      -- SPLIT  |PARTITIONED|
-                        exchange 
-                        -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                          select (function-call: algebricks:eq, Args:[%0->$$10, GERMANY])
-                          -- STREAM_SELECT  |PARTITIONED|
-                            exchange 
-                            -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                              replicate 
-                              -- SPLIT  |PARTITIONED|
-                                exchange 
-                                -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                                  data-scan [$$9, $$10]<-[$$9, $$10, $$11, $$12] <- default.nation
-                                  -- DATASOURCE_SCAN  |PARTITIONED|
-                                    exchange 
-                                    -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                                      empty-tuple-source
-                                      -- EMPTY_TUPLE_SOURCE  |PARTITIONED|
-              exchange 
-              -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                project ([$$5, $$6])
-                -- STREAM_PROJECT  |PARTITIONED|
-                  exchange 
-                  -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                    replicate 
-                    -- SPLIT  |PARTITIONED|
-                      exchange 
-                      -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                        select (function-call: algebricks:eq, Args:[%0->$$6, FRANCE])
-                        -- STREAM_SELECT  |PARTITIONED|
-                          project ([$$5, $$6])
-                          -- STREAM_PROJECT  |PARTITIONED|
-                            assign [$$5, $$6] <- [%0->$$9, %0->$$10]
-                            -- ASSIGN  |PARTITIONED|
-                              exchange 
-                              -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                                replicate 
-                                -- SPLIT  |PARTITIONED|
-                                  exchange 
-                                  -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                                    data-scan [$$9, $$10]<-[$$9, $$10, $$11, $$12] <- default.nation
-                                    -- DATASOURCE_SCAN  |PARTITIONED|
-                                      exchange 
-                                      -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                                        empty-tuple-source
-                                        -- EMPTY_TUPLE_SOURCE  |PARTITIONED|
-      exchange 
-      -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-        project ([$$10, $$14, $$9, $$13])
-        -- STREAM_PROJECT  |PARTITIONED|
-          exchange 
-          -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-            join (true)
-            -- NESTED_LOOP  |PARTITIONED|
-              exchange 
-              -- BROADCAST_EXCHANGE  |PARTITIONED|
-                project ([$$13, $$14])
-                -- STREAM_PROJECT  |PARTITIONED|
-                  assign [$$13, $$14] <- [%0->$$5, %0->$$6]
-                  -- ASSIGN  |PARTITIONED|
-                    exchange 
-                    -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                      replicate 
-                      -- SPLIT  |PARTITIONED|
-                        exchange 
-                        -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                          select (function-call: algebricks:eq, Args:[%0->$$6, FRANCE])
-                          -- STREAM_SELECT  |PARTITIONED|
-                            project ([$$5, $$6])
-                            -- STREAM_PROJECT  |PARTITIONED|
-                              assign [$$5, $$6] <- [%0->$$9, %0->$$10]
-                              -- ASSIGN  |PARTITIONED|
-                                exchange 
-                                -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                                  replicate 
-                                  -- SPLIT  |PARTITIONED|
-                                    exchange 
-                                    -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                                      data-scan [$$9, $$10]<-[$$9, $$10, $$11, $$12] <- default.nation
-                                      -- DATASOURCE_SCAN  |PARTITIONED|
-                                        exchange 
-                                        -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                                          empty-tuple-source
-                                          -- EMPTY_TUPLE_SOURCE  |PARTITIONED|
-              exchange 
-              -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                project ([$$9, $$10])
-                -- STREAM_PROJECT  |PARTITIONED|
-                  exchange 
-                  -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                    replicate 
-                    -- SPLIT  |PARTITIONED|
-                      exchange 
-                      -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                        select (function-call: algebricks:eq, Args:[%0->$$10, GERMANY])
-                        -- STREAM_SELECT  |PARTITIONED|
-                          exchange 
-                          -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                            replicate 
-                            -- SPLIT  |PARTITIONED|
-                              exchange 
-                              -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                                data-scan [$$9, $$10]<-[$$9, $$10, $$11, $$12] <- default.nation
-                                -- DATASOURCE_SCAN  |PARTITIONED|
-                                  exchange 
-                                  -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                                    empty-tuple-source
-                                    -- EMPTY_TUPLE_SOURCE  |PARTITIONED|
-write [%0->$$47, %0->$$48, %0->$$49, %0->$$50]
--- SINK_WRITE  |PARTITIONED|
-  project ([$$47, $$48, $$49, $$50])
-  -- STREAM_PROJECT  |PARTITIONED|
-    exchange 
-    -- SORT_MERGE_EXCHANGE [$$47(ASC), $$48(ASC), $$49(ASC) ]  |PARTITIONED|
-      group by ([$$47 := %0->$$53; $$48 := %0->$$54; $$49 := %0->$$55]) decor ([]) {
-                aggregate [$$50] <- [function-call: hive:sum(FINAL), Args:[%0->$$52]]
-                -- AGGREGATE  |LOCAL|
-                  nested tuple source
-                  -- NESTED_TUPLE_SOURCE  |LOCAL|
-             }
-      -- PRE_CLUSTERED_GROUP_BY[$$53, $$54, $$55]  |PARTITIONED|
-        exchange 
-        -- HASH_PARTITION_MERGE_EXCHANGE MERGE:[$$53(ASC), $$54(ASC), $$55(ASC)] HASH:[$$53, $$54, $$55]  |PARTITIONED|
-          group by ([$$53 := %0->$$1; $$54 := %0->$$2; $$55 := %0->$$45]) decor ([]) {
-                    aggregate [$$52] <- [function-call: hive:sum(PARTIAL1), Args:[%0->$$46]]
-                    -- AGGREGATE  |LOCAL|
-                      nested tuple source
-                      -- NESTED_TUPLE_SOURCE  |LOCAL|
-                 }
-          -- SORT_GROUP_BY[$$1, $$2, $$45]  |PARTITIONED|
-            exchange 
-            -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-              project ([$$1, $$2, $$45, $$46])
-              -- STREAM_PROJECT  |PARTITIONED|
-                assign [$$45, $$46] <- [function-call: hive:org.apache.hadoop.hive.ql.udf.UDFYear, Args:[%0->$$30], function-call: hive:org.apache.hadoop.hive.ql.udf.UDFOPMultiply, Args:[%0->$$25, function-call: hive:org.apache.hadoop.hive.ql.udf.UDFOPMinus, Args:[1, %0->$$26]]]
-                -- ASSIGN  |PARTITIONED|
-                  project ([$$1, $$2, $$30, $$25, $$26])
-                  -- STREAM_PROJECT  |PARTITIONED|
-                    exchange 
-                    -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                      join (function-call: algebricks:and, Args:[function-call: algebricks:eq, Args:[%0->$$15, %0->$$4], function-call: algebricks:eq, Args:[%0->$$8, %0->$$3]])
-                      -- HYBRID_HASH_JOIN [$$15, $$8][$$4, $$3]  |PARTITIONED|
-                        exchange 
-                        -- HASH_PARTITION_EXCHANGE [$$15, $$8]  |PARTITIONED|
-                          project ([$$8, $$30, $$25, $$26, $$15])
-                          -- STREAM_PROJECT  |PARTITIONED|
-                            exchange 
-                            -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                              join (function-call: algebricks:eq, Args:[%0->$$22, %0->$$5])
-                              -- HYBRID_HASH_JOIN [$$22][$$5]  |PARTITIONED|
-                                exchange 
-                                -- HASH_PARTITION_EXCHANGE [$$22]  |PARTITIONED|
-                                  project ([$$15, $$30, $$25, $$26, $$22])
-                                  -- STREAM_PROJECT  |PARTITIONED|
-                                    exchange 
-                                    -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                                      join (function-call: algebricks:eq, Args:[%0->$$37, %0->$$12])
-                                      -- HYBRID_HASH_JOIN [$$37][$$12]  |PARTITIONED|
-                                        exchange 
-                                        -- HASH_PARTITION_EXCHANGE [$$37]  |PARTITIONED|
-                                          project ([$$37, $$22, $$25, $$26, $$30])
-                                          -- STREAM_PROJECT  |PARTITIONED|
-                                            exchange 
-                                            -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                                              join (function-call: algebricks:eq, Args:[%0->$$20, %0->$$36])
-                                              -- HYBRID_HASH_JOIN [$$20][$$36]  |PARTITIONED|
-                                                exchange 
-                                                -- HASH_PARTITION_EXCHANGE [$$20]  |PARTITIONED|
-                                                  select (function-call: algebricks:and, Args:[function-call: algebricks:ge, Args:[%0->$$30, 1995-01-01], function-call: algebricks:le, Args:[%0->$$30, 1996-12-31]])
-                                                  -- STREAM_SELECT  |PARTITIONED|
-                                                    exchange 
-                                                    -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                                                      data-scan [$$20, $$22, $$25, $$26, $$30]<-[$$20, $$21, $$22, $$23, $$24, $$25, $$26, $$27, $$28, $$29, $$30, $$31, $$32, $$33, $$34, $$35] <- default.lineitem
-                                                      -- DATASOURCE_SCAN  |PARTITIONED|
-                                                        exchange 
-                                                        -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                                                          empty-tuple-source
-                                                          -- EMPTY_TUPLE_SOURCE  |PARTITIONED|
-                                                exchange 
-                                                -- HASH_PARTITION_EXCHANGE [$$36]  |PARTITIONED|
-                                                  data-scan [$$36, $$37]<-[$$36, $$37, $$38, $$39, $$40, $$41, $$42, $$43, $$44] <- default.orders
-                                                  -- DATASOURCE_SCAN  |PARTITIONED|
-                                                    exchange 
-                                                    -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                                                      empty-tuple-source
-                                                      -- EMPTY_TUPLE_SOURCE  |PARTITIONED|
-                                        exchange 
-                                        -- HASH_PARTITION_EXCHANGE [$$12]  |PARTITIONED|
-                                          data-scan [$$12, $$15]<-[$$12, $$13, $$14, $$15, $$16, $$17, $$18, $$19] <- default.customer
-                                          -- DATASOURCE_SCAN  |PARTITIONED|
-                                            exchange 
-                                            -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                                              empty-tuple-source
-                                              -- EMPTY_TUPLE_SOURCE  |PARTITIONED|
-                                exchange 
-                                -- HASH_PARTITION_EXCHANGE [$$5]  |PARTITIONED|
-                                  data-scan [$$5, $$8]<-[$$5, $$6, $$7, $$8, $$9, $$10, $$11] <- default.supplier
-                                  -- DATASOURCE_SCAN  |PARTITIONED|
-                                    exchange 
-                                    -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                                      empty-tuple-source
-                                      -- EMPTY_TUPLE_SOURCE  |PARTITIONED|
-                        exchange 
-                        -- HASH_PARTITION_EXCHANGE [$$4, $$3]  |PARTITIONED|
-                          data-scan [$$4, $$3, $$1, $$2]<-[$$1, $$2, $$3, $$4] <- default.q7_volume_shipping_tmp
-                          -- DATASOURCE_SCAN  |PARTITIONED|
-                            exchange 
-                            -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
-                              empty-tuple-source
-                              -- EMPTY_TUPLE_SOURCE  |PARTITIONED|


Mime
View raw message