Gitiles
Code Review Sign In
asterix-gerrit.ics.uci.edu / hivesterix / fac563580c797fd92e5f37bbc7809a414d17d809 / . / hivesterix-dist / src / test / resources / optimizerts / results / q12_shipping.plan
blob: a6aa7307e924baae2e39a882f3311801a30c503d [file] [log] [blame]
buyingyicf48fb52012-11-02 00:31:31 +0000[diff] [blame]1write [%0->$$26, %0->$$29, %0->$$30]
2-- SINK_WRITE |PARTITIONED|
3 project ([$$26, $$29, $$30])
4 -- STREAM_PROJECT |PARTITIONED|
5 assign [$$29, $$30] <- [function-call: hive:org.apache.hadoop.hive.ql.udf.UDFToDouble, Args:[%0->$$27], function-call: hive:org.apache.hadoop.hive.ql.udf.UDFToDouble, Args:[%0->$$28]]
6 -- ASSIGN |PARTITIONED|
7 exchange
8 -- SORT_MERGE_EXCHANGE [$$26(ASC) ] |PARTITIONED|
Yingyi Bufac56352014-05-27 17:46:41 -0700[diff] [blame^]9 group by ([$$26 := %0->$$34]) decor ([]) {
10 aggregate [$$27, $$28] <- [function-call: hive:sum(FINAL), Args:[%0->$$32], function-call: hive:sum(FINAL), Args:[%0->$$33]]
11 -- AGGREGATE |LOCAL|
12 nested tuple source
13 -- NESTED_TUPLE_SOURCE |LOCAL|
14 }
15 -- PRE_CLUSTERED_GROUP_BY[$$34] |PARTITIONED|
buyingyicf48fb52012-11-02 00:31:31 +0000[diff] [blame]16 exchange
Yingyi Bufac56352014-05-27 17:46:41 -0700[diff] [blame^]17 -- HASH_PARTITION_MERGE_EXCHANGE MERGE:[$$34(ASC)] HASH:[$$34] |PARTITIONED|
18 group by ([$$34 := %0->$$24]) decor ([]) {
19 aggregate [$$32, $$33] <- [function-call: hive:sum(PARTIAL1), Args:[function-call: hive:org.apache.hadoop.hive.ql.udf.generic.GenericUDFWhen, Args:[function-call: algebricks:or, Args:[function-call: algebricks:eq, Args:[%0->$$6, 1-URGENT], function-call: algebricks:eq, Args:[%0->$$6, 2-HIGH]], 1, 0]], function-call: hive:sum(PARTIAL1), Args:[function-call: hive:org.apache.hadoop.hive.ql.udf.generic.GenericUDFWhen, Args:[function-call: algebricks:and, Args:[function-call: algebricks:neq, Args:[%0->$$6, 1-URGENT], function-call: algebricks:neq, Args:[%0->$$6, 2-HIGH]], 1, 0]]]
buyingyicf48fb52012-11-02 00:31:31 +0000[diff] [blame]20 -- AGGREGATE |LOCAL|
21 nested tuple source
22 -- NESTED_TUPLE_SOURCE |LOCAL|
23 }
Yingyi Bufac56352014-05-27 17:46:41 -0700[diff] [blame^]24 -- SORT_GROUP_BY[$$24] |PARTITIONED|
buyingyicf48fb52012-11-02 00:31:31 +0000[diff] [blame]25 exchange
Yingyi Bufac56352014-05-27 17:46:41 -0700[diff] [blame^]26 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
27 project ([$$6, $$24])
28 -- STREAM_PROJECT |PARTITIONED|
buyingyicf48fb52012-11-02 00:31:31 +0000[diff] [blame]29 exchange
30 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
Yingyi Bufac56352014-05-27 17:46:41 -0700[diff] [blame^]31 join (function-call: algebricks:eq, Args:[%0->$$10, %0->$$1])
32 -- HYBRID_HASH_JOIN [$$10][$$1] |PARTITIONED|
buyingyicf48fb52012-11-02 00:31:31 +0000[diff] [blame]33 exchange
Yingyi Bufac56352014-05-27 17:46:41 -0700[diff] [blame^]34 -- HASH_PARTITION_EXCHANGE [$$10] |PARTITIONED|
35 project ([$$10, $$24])
36 -- STREAM_PROJECT |PARTITIONED|
37 select (function-call: algebricks:and, Args:[function-call: algebricks:lt, Args:[%0->$$21, %0->$$22], function-call: algebricks:lt, Args:[%0->$$20, %0->$$21], function-call: algebricks:ge, Args:[%0->$$22, 1994-01-01], function-call: algebricks:lt, Args:[%0->$$22, 1995-01-01], function-call: algebricks:or, Args:[function-call: algebricks:eq, Args:[%0->$$24, MAIL], function-call: algebricks:eq, Args:[%0->$$24, SHIP]]])
38 -- STREAM_SELECT |PARTITIONED|
39 exchange
40 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
41 data-scan [$$21, $$20, $$22, $$24, $$10]<-[$$10, $$11, $$12, $$13, $$14, $$15, $$16, $$17, $$18, $$19, $$20, $$21, $$22, $$23, $$24, $$25] <- default.lineitem
42 -- DATASOURCE_SCAN |PARTITIONED|
buyingyicf48fb52012-11-02 00:31:31 +0000[diff] [blame]43 exchange
44 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
Yingyi Bufac56352014-05-27 17:46:41 -0700[diff] [blame^]45 empty-tuple-source
46 -- EMPTY_TUPLE_SOURCE |PARTITIONED|
47 exchange
48 -- HASH_PARTITION_EXCHANGE [$$1] |PARTITIONED|
49 data-scan [$$1, $$6]<-[$$1, $$2, $$3, $$4, $$5, $$6, $$7, $$8, $$9] <- default.orders
50 -- DATASOURCE_SCAN |PARTITIONED|
buyingyicf48fb52012-11-02 00:31:31 +0000[diff] [blame]51 exchange
Yingyi Bufac56352014-05-27 17:46:41 -0700[diff] [blame^]52 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
53 empty-tuple-source
54 -- EMPTY_TUPLE_SOURCE |PARTITIONED|