| 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)] |LOCAL| |
| 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| |
| } |
| -- EXTERNAL_GROUP_BY[$$52] |PARTITIONED| |
| exchange |
| -- HASH_PARTITION_EXCHANGE [$$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| |
| } |
| -- EXTERNAL_GROUP_BY[$$42] |LOCAL| |
| 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:lt, Args:[%0->$$13, 1995-01-01], 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| |
