| buyingyi | cf48fb5 | 2012-11-02 00:31:31 +0000 | [diff] [blame] | 1 | write [%0->$$17, %0->$$18] |
| 2 | -- SINK_WRITE |PARTITIONED| |
| 3 | project ([$$17, $$18]) |
| 4 | -- STREAM_PROJECT |PARTITIONED| |
| 5 | exchange |
| 6 | -- ONE_TO_ONE_EXCHANGE |PARTITIONED| |
| 7 | group by ([$$17 := %0->$$21]) decor ([]) { |
| 8 | aggregate [$$18] <- [function-call: hive:sum(FINAL), Args:[%0->$$20]] |
| 9 | -- AGGREGATE |LOCAL| |
| 10 | nested tuple source |
| 11 | -- NESTED_TUPLE_SOURCE |LOCAL| |
| 12 | } |
| 13 | -- EXTERNAL_GROUP_BY[$$21] |PARTITIONED| |
| 14 | exchange |
| 15 | -- HASH_PARTITION_EXCHANGE [$$21] |PARTITIONED| |
| 16 | group by ([$$21 := %0->$$3]) decor ([]) { |
| 17 | aggregate [$$20] <- [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]]]] |
| 18 | -- AGGREGATE |LOCAL| |
| 19 | nested tuple source |
| 20 | -- NESTED_TUPLE_SOURCE |LOCAL| |
| 21 | } |
| 22 | -- EXTERNAL_GROUP_BY[$$3] |LOCAL| |
| 23 | exchange |
| 24 | -- ONE_TO_ONE_EXCHANGE |PARTITIONED| |
| 25 | project ([$$3, $$6, $$7]) |
| 26 | -- STREAM_PROJECT |PARTITIONED| |
| 27 | select (function-call: algebricks:and, Args:[function-call: algebricks:ge, Args:[%0->$$11, 1996-01-01], function-call: algebricks:lt, Args:[%0->$$11, 1996-04-01], function-call: algebricks:ge, Args:[%0->$$11, 1996-01-01], function-call: algebricks:lt, Args:[%0->$$11, 1996-04-01]]) |
| 28 | -- STREAM_SELECT |PARTITIONED| |
| 29 | exchange |
| 30 | -- ONE_TO_ONE_EXCHANGE |PARTITIONED| |
| 31 | data-scan [$$3, $$6, $$7, $$11]<-[$$1, $$2, $$3, $$4, $$5, $$6, $$7, $$8, $$9, $$10, $$11, $$12, $$13, $$14, $$15, $$16] <- default.lineitem |
| 32 | -- DATASOURCE_SCAN |PARTITIONED| |
| 33 | exchange |
| 34 | -- ONE_TO_ONE_EXCHANGE |PARTITIONED| |
| 35 | empty-tuple-source |
| 36 | -- EMPTY_TUPLE_SOURCE |PARTITIONED| |
| 37 | write [%0->$$3] |
| 38 | -- SINK_WRITE |PARTITIONED| |
| 39 | exchange |
| 40 | -- ONE_TO_ONE_EXCHANGE |PARTITIONED| |
| 41 | group by ([]) decor ([]) { |
| 42 | aggregate [$$3] <- [function-call: hive:max(FINAL), Args:[%0->$$5]] |
| 43 | -- AGGREGATE |LOCAL| |
| 44 | nested tuple source |
| 45 | -- NESTED_TUPLE_SOURCE |LOCAL| |
| 46 | } |
| 47 | -- PRE_CLUSTERED_GROUP_BY[] |PARTITIONED| |
| 48 | exchange |
| 49 | -- HASH_PARTITION_EXCHANGE [] |PARTITIONED| |
| 50 | group by ([]) decor ([]) { |
| 51 | aggregate [$$5] <- [function-call: hive:max(PARTIAL1), Args:[%0->$$2]] |
| 52 | -- AGGREGATE |LOCAL| |
| 53 | nested tuple source |
| 54 | -- NESTED_TUPLE_SOURCE |LOCAL| |
| 55 | } |
| 56 | -- PRE_CLUSTERED_GROUP_BY[] |LOCAL| |
| 57 | exchange |
| 58 | -- ONE_TO_ONE_EXCHANGE |PARTITIONED| |
| 59 | data-scan [$$2]<-[$$1, $$2] <- default.revenue |
| 60 | -- DATASOURCE_SCAN |PARTITIONED| |
| 61 | exchange |
| 62 | -- ONE_TO_ONE_EXCHANGE |PARTITIONED| |
| 63 | empty-tuple-source |
| 64 | -- EMPTY_TUPLE_SOURCE |PARTITIONED| |
| 65 | write [%0->$$2, %0->$$3, %0->$$4, %0->$$6, %0->$$10] |
| 66 | -- SINK_WRITE |PARTITIONED| |
| 67 | exchange |
| 68 | -- SORT_MERGE_EXCHANGE [$$2(ASC) ] |PARTITIONED| |
| 69 | order (ASC, %0->$$2) |
| 70 | -- STABLE_SORT [$$2(ASC)] |LOCAL| |
| 71 | exchange |
| 72 | -- ONE_TO_ONE_EXCHANGE |PARTITIONED| |
| 73 | project ([$$2, $$3, $$4, $$6, $$10]) |
| 74 | -- STREAM_PROJECT |PARTITIONED| |
| 75 | exchange |
| 76 | -- ONE_TO_ONE_EXCHANGE |PARTITIONED| |
| 77 | join (function-call: algebricks:eq, Args:[%0->$$1, %0->$$10]) |
| 78 | -- HYBRID_HASH_JOIN [$$1][$$10] |PARTITIONED| |
| 79 | exchange |
| 80 | -- HASH_PARTITION_EXCHANGE [$$1] |PARTITIONED| |
| 81 | data-scan []<-[$$1] <- default.max_revenue |
| 82 | -- DATASOURCE_SCAN |PARTITIONED| |
| 83 | exchange |
| 84 | -- ONE_TO_ONE_EXCHANGE |PARTITIONED| |
| 85 | empty-tuple-source |
| 86 | -- EMPTY_TUPLE_SOURCE |PARTITIONED| |
| 87 | exchange |
| 88 | -- HASH_PARTITION_EXCHANGE [$$10] |PARTITIONED| |
| 89 | project ([$$10, $$2, $$3, $$4, $$6]) |
| 90 | -- STREAM_PROJECT |PARTITIONED| |
| 91 | exchange |
| 92 | -- ONE_TO_ONE_EXCHANGE |PARTITIONED| |
| 93 | join (function-call: algebricks:eq, Args:[%0->$$9, %0->$$2]) |
| 94 | -- HYBRID_HASH_JOIN [$$9][$$2] |PARTITIONED| |
| 95 | exchange |
| 96 | -- HASH_PARTITION_EXCHANGE [$$9] |PARTITIONED| |
| 97 | data-scan []<-[$$9, $$10] <- default.revenue |
| 98 | -- DATASOURCE_SCAN |PARTITIONED| |
| 99 | exchange |
| 100 | -- ONE_TO_ONE_EXCHANGE |PARTITIONED| |
| 101 | empty-tuple-source |
| 102 | -- EMPTY_TUPLE_SOURCE |PARTITIONED| |
| 103 | exchange |
| 104 | -- HASH_PARTITION_EXCHANGE [$$2] |PARTITIONED| |
| 105 | data-scan [$$2, $$3, $$4, $$6]<-[$$2, $$3, $$4, $$5, $$6, $$7, $$8] <- default.supplier |
| 106 | -- DATASOURCE_SCAN |PARTITIONED| |
| 107 | exchange |
| 108 | -- ONE_TO_ONE_EXCHANGE |PARTITIONED| |
| 109 | empty-tuple-source |
| 110 | -- EMPTY_TUPLE_SOURCE |PARTITIONED| |