| 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 |LOCAL| |
| order (ASC, %0->$$1) |
| -- STABLE_SORT [$$1(ASC)] |LOCAL| |
| 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| |
| order (ASC, %0->$$11) |
| -- STABLE_SORT [$$11(ASC)] |LOCAL| |
| exchange |
| -- ONE_TO_ONE_EXCHANGE |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| |
| } |
| -- EXTERNAL_GROUP_BY[$$16] |PARTITIONED| |
| exchange |
| -- HASH_PARTITION_EXCHANGE [$$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| |
| } |
| -- EXTERNAL_GROUP_BY[$$7] |LOCAL| |
| 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:lt, Args:[%0->$$6, 1993-10-01], 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| |
