Return-Path: X-Original-To: apmail-asterixdb-commits-archive@minotaur.apache.org Delivered-To: apmail-asterixdb-commits-archive@minotaur.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 3BBA817BD1 for ; Fri, 24 Apr 2015 18:46:37 +0000 (UTC) Received: (qmail 24517 invoked by uid 500); 24 Apr 2015 18:46:37 -0000 Delivered-To: apmail-asterixdb-commits-archive@asterixdb.apache.org Received: (qmail 24481 invoked by uid 500); 24 Apr 2015 18:46:37 -0000 Mailing-List: contact commits-help@asterixdb.incubator.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@asterixdb.incubator.apache.org Delivered-To: mailing list commits@asterixdb.incubator.apache.org Received: (qmail 24472 invoked by uid 99); 24 Apr 2015 18:46:37 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 24 Apr 2015 18:46:37 +0000 X-ASF-Spam-Status: No, hits=0.0 required=5.0 tests=LOTS_OF_MONEY,SPF_PASS X-Spam-Check-By: apache.org Received-SPF: pass (athena.apache.org: domain of root@apache.org designates 54.191.145.13 as permitted sender) Received: from [54.191.145.13] (HELO mx1-us-west.apache.org) (54.191.145.13) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 24 Apr 2015 18:46:27 +0000 Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by mx1-us-west.apache.org (ASF Mail Server at mx1-us-west.apache.org) with SMTP id B6BE025FD1 for ; Fri, 24 Apr 2015 18:45:29 +0000 (UTC) Received: (qmail 19023 invoked by uid 99); 24 Apr 2015 18:45:29 -0000 Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 24 Apr 2015 18:45:29 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id 8B4E3E091A; Fri, 24 Apr 2015 18:45:29 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: imaxon@apache.org To: commits@asterixdb.incubator.apache.org Date: Fri, 24 Apr 2015 18:46:04 -0000 Message-Id: <71e042bedcc6488ca059a3cc4c1fe24f@git.apache.org> In-Reply-To: <0a743a5c99b842bf8de294f7df7a3d2b@git.apache.org> References: <0a743a5c99b842bf8de294f7df7a3d2b@git.apache.org> X-Mailer: ASF-Git Admin Mailer 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 X-Virus-Checked: Checked by ClamAV on apache.org 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|