| write [%0->$$53, %0->$$54, %0->$$55] |
| -- SINK_WRITE |PARTITIONED| |
| project ([$$53, $$54, $$55]) |
| -- STREAM_PROJECT |PARTITIONED| |
| exchange |
| -- SORT_MERGE_EXCHANGE [$$53(ASC), $$54(DESC) ] |PARTITIONED| |
| order (ASC, %0->$$53) (DESC, %0->$$54) |
| -- STABLE_SORT [$$53(ASC), $$54(DESC)] |LOCAL| |
| exchange |
| -- ONE_TO_ONE_EXCHANGE |PARTITIONED| |
| group by ([$$53 := %0->$$58; $$54 := %0->$$59]) decor ([]) { |
| aggregate [$$55] <- [function-call: hive:sum(FINAL), Args:[%0->$$57]] |
| -- AGGREGATE |LOCAL| |
| nested tuple source |
| -- NESTED_TUPLE_SOURCE |LOCAL| |
| } |
| -- EXTERNAL_GROUP_BY[$$58, $$59] |PARTITIONED| |
| exchange |
| -- HASH_PARTITION_EXCHANGE [$$58, $$59] |PARTITIONED| |
| group by ([$$58 := %0->$$48; $$59 := %0->$$51]) decor ([]) { |
| aggregate [$$57] <- [function-call: hive:sum(PARTIAL1), Args:[%0->$$52]] |
| -- AGGREGATE |LOCAL| |
| nested tuple source |
| -- NESTED_TUPLE_SOURCE |LOCAL| |
| } |
| -- EXTERNAL_GROUP_BY[$$48, $$51] |LOCAL| |
| exchange |
| -- ONE_TO_ONE_EXCHANGE |PARTITIONED| |
| project ([$$48, $$51, $$52]) |
| -- STREAM_PROJECT |PARTITIONED| |
| assign [$$51, $$52] <- [function-call: hive:org.apache.hadoop.hive.ql.udf.UDFYear, Args:[%0->$$5], function-call: hive:org.apache.hadoop.hive.ql.udf.UDFOPMinus, Args:[function-call: hive:org.apache.hadoop.hive.ql.udf.UDFOPMultiply, Args:[%0->$$29, function-call: hive:org.apache.hadoop.hive.ql.udf.UDFOPMinus, Args:[1, %0->$$30]], function-call: hive:org.apache.hadoop.hive.ql.udf.UDFOPMultiply, Args:[%0->$$22, %0->$$28]]] |
| -- ASSIGN |PARTITIONED| |
| project ([$$5, $$29, $$30, $$28, $$48, $$22]) |
| -- STREAM_PROJECT |PARTITIONED| |
| exchange |
| -- ONE_TO_ONE_EXCHANGE |PARTITIONED| |
| join (function-call: algebricks:eq, Args:[%0->$$24, %0->$$1]) |
| -- HYBRID_HASH_JOIN [$$24][$$1] |PARTITIONED| |
| exchange |
| -- HASH_PARTITION_EXCHANGE [$$24] |PARTITIONED| |
| project ([$$29, $$30, $$28, $$24, $$48, $$22]) |
| -- STREAM_PROJECT |PARTITIONED| |
| exchange |
| -- ONE_TO_ONE_EXCHANGE |PARTITIONED| |
| join (function-call: algebricks:eq, Args:[%0->$$25, %0->$$10]) |
| -- HYBRID_HASH_JOIN [$$25][$$10] |PARTITIONED| |
| exchange |
| -- HASH_PARTITION_EXCHANGE [$$25] |PARTITIONED| |
| project ([$$22, $$29, $$30, $$28, $$25, $$24, $$48]) |
| -- STREAM_PROJECT |PARTITIONED| |
| exchange |
| -- ONE_TO_ONE_EXCHANGE |PARTITIONED| |
| join (function-call: algebricks:and, Args:[function-call: algebricks:eq, Args:[%0->$$26, %0->$$20], function-call: algebricks:eq, Args:[%0->$$25, %0->$$19]]) |
| -- HYBRID_HASH_JOIN [$$26, $$25][$$20, $$19] |PARTITIONED| |
| exchange |
| -- ONE_TO_ONE_EXCHANGE |PARTITIONED| |
| project ([$$48, $$24, $$25, $$26, $$28, $$29, $$30]) |
| -- STREAM_PROJECT |PARTITIONED| |
| exchange |
| -- ONE_TO_ONE_EXCHANGE |PARTITIONED| |
| join (function-call: algebricks:eq, Args:[%0->$$26, %0->$$40]) |
| -- HYBRID_HASH_JOIN [$$26][$$40] |PARTITIONED| |
| exchange |
| -- HASH_PARTITION_EXCHANGE [$$26] |PARTITIONED| |
| data-scan [$$26, $$24, $$25, $$28, $$29, $$30]<-[$$24, $$25, $$26, $$27, $$28, $$29, $$30, $$31, $$32, $$33, $$34, $$35, $$36, $$37, $$38, $$39] <- default.lineitem |
| -- DATASOURCE_SCAN |PARTITIONED| |
| exchange |
| -- ONE_TO_ONE_EXCHANGE |PARTITIONED| |
| empty-tuple-source |
| -- EMPTY_TUPLE_SOURCE |PARTITIONED| |
| exchange |
| -- HASH_PARTITION_EXCHANGE [$$40] |PARTITIONED| |
| project ([$$40, $$48]) |
| -- STREAM_PROJECT |PARTITIONED| |
| exchange |
| -- ONE_TO_ONE_EXCHANGE |PARTITIONED| |
| join (function-call: algebricks:eq, Args:[%0->$$43, %0->$$47]) |
| -- HYBRID_HASH_JOIN [$$43][$$47] |PARTITIONED| |
| exchange |
| -- HASH_PARTITION_EXCHANGE [$$43] |PARTITIONED| |
| data-scan [$$43, $$40]<-[$$40, $$41, $$42, $$43, $$44, $$45, $$46] <- default.supplier |
| -- DATASOURCE_SCAN |PARTITIONED| |
| exchange |
| -- ONE_TO_ONE_EXCHANGE |PARTITIONED| |
| empty-tuple-source |
| -- EMPTY_TUPLE_SOURCE |PARTITIONED| |
| exchange |
| -- HASH_PARTITION_EXCHANGE [$$47] |PARTITIONED| |
| data-scan [$$47, $$48]<-[$$47, $$48, $$49, $$50] <- default.nation |
| -- 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, $$19, $$22]<-[$$19, $$20, $$21, $$22, $$23] <- default.partsupp |
| -- DATASOURCE_SCAN |PARTITIONED| |
| exchange |
| -- ONE_TO_ONE_EXCHANGE |PARTITIONED| |
| empty-tuple-source |
| -- EMPTY_TUPLE_SOURCE |PARTITIONED| |
| exchange |
| -- HASH_PARTITION_EXCHANGE [$$10] |PARTITIONED| |
| project ([$$10]) |
| -- STREAM_PROJECT |PARTITIONED| |
| select (function-call: hive:org.apache.hadoop.hive.ql.udf.UDFLike, Args:[%0->$$11, %green%]) |
| -- STREAM_SELECT |PARTITIONED| |
| exchange |
| -- ONE_TO_ONE_EXCHANGE |PARTITIONED| |
| data-scan [$$10, $$11]<-[$$10, $$11, $$12, $$13, $$14, $$15, $$16, $$17, $$18] <- default.part |
| -- 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, $$5]<-[$$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| |
