write [%0->$$38, %0->$$39, %0->$$45, %0->$$40, %0->$$42, %0->$$43, %0->$$41, %0->$$44]
-- SINK_WRITE  |UNPARTITIONED|
  project ([$$38, $$39, $$45, $$40, $$42, $$43, $$41, $$44])
  -- STREAM_PROJECT  |PARTITIONED|
    limit 20
    -- STREAM_LIMIT  |UNPARTITIONED|
      limit 20
      -- STREAM_LIMIT  |UNPARTITIONED|
        exchange 
        -- SORT_MERGE_EXCHANGE [$$45(DESC) ]  |PARTITIONED|
          limit 20
          -- STREAM_LIMIT  |LOCAL|
            exchange 
            -- ONE_TO_ONE_EXCHANGE  |LOCAL|
              order (DESC, %0->$$45) 
              -- STABLE_SORT [$$45(DESC)]  |LOCAL|
                exchange 
                -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
                  group by ([$$38 := %0->$$48; $$39 := %0->$$49; $$40 := %0->$$50; $$41 := %0->$$51; $$42 := %0->$$52; $$43 := %0->$$53; $$44 := %0->$$54]) decor ([]) {
                            aggregate [$$45] <- [function-call: hive:sum(FINAL), Args:[%0->$$47]]
                            -- AGGREGATE  |LOCAL|
                              nested tuple source
                              -- NESTED_TUPLE_SOURCE  |LOCAL|
                         }
                  -- EXTERNAL_GROUP_BY[$$48, $$49, $$50, $$51, $$52, $$53, $$54]  |PARTITIONED|
                    exchange 
                    -- HASH_PARTITION_EXCHANGE [$$48, $$49, $$50, $$51, $$52, $$53, $$54]  |PARTITIONED|
                      group by ([$$48 := %0->$$21; $$49 := %0->$$22; $$50 := %0->$$26; $$51 := %0->$$25; $$52 := %0->$$18; $$53 := %0->$$23; $$54 := %0->$$28]) decor ([]) {
                                aggregate [$$47] <- [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]]]]
                                -- AGGREGATE  |LOCAL|
                                  nested tuple source
                                  -- NESTED_TUPLE_SOURCE  |LOCAL|
                             }
                      -- EXTERNAL_GROUP_BY[$$21, $$22, $$26, $$25, $$18, $$23, $$28]  |LOCAL|
                        exchange 
                        -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
                          project ([$$21, $$22, $$23, $$25, $$26, $$28, $$18, $$6, $$7])
                          -- STREAM_PROJECT  |PARTITIONED|
                            exchange 
                            -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
                              join (function-call: algebricks:eq, Args:[%0->$$1, %0->$$29])
                              -- HYBRID_HASH_JOIN [$$1][$$29]  |PARTITIONED|
                                exchange 
                                -- HASH_PARTITION_EXCHANGE [$$1]  |PARTITIONED|
                                  project ([$$1, $$6, $$7])
                                  -- STREAM_PROJECT  |PARTITIONED|
                                    select (function-call: algebricks:eq, Args:[%0->$$9, R])
                                    -- STREAM_SELECT  |PARTITIONED|
                                      exchange 
                                      -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
                                        data-scan [$$1, $$6, $$7, $$9]<-[$$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|
                                exchange 
                                -- HASH_PARTITION_EXCHANGE [$$29]  |PARTITIONED|
                                  project ([$$29, $$21, $$22, $$23, $$25, $$26, $$28, $$18])
                                  -- STREAM_PROJECT  |PARTITIONED|
                                    exchange 
                                    -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
                                      join (function-call: algebricks:eq, Args:[%0->$$17, %0->$$24])
                                      -- HYBRID_HASH_JOIN [$$17][$$24]  |PARTITIONED|
                                        exchange 
                                        -- HASH_PARTITION_EXCHANGE [$$17]  |PARTITIONED|
                                          data-scan [$$17, $$18]<-[$$17, $$18, $$19, $$20] <- default.nation
                                          -- DATASOURCE_SCAN  |PARTITIONED|
                                            exchange 
                                            -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
                                              empty-tuple-source
                                              -- EMPTY_TUPLE_SOURCE  |PARTITIONED|
                                        exchange 
                                        -- HASH_PARTITION_EXCHANGE [$$24]  |PARTITIONED|
                                          project ([$$24, $$21, $$22, $$23, $$25, $$26, $$28, $$29])
                                          -- STREAM_PROJECT  |PARTITIONED|
                                            exchange 
                                            -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
                                              join (function-call: algebricks:eq, Args:[%0->$$30, %0->$$21])
                                              -- HYBRID_HASH_JOIN [$$30][$$21]  |PARTITIONED|
                                                exchange 
                                                -- HASH_PARTITION_EXCHANGE [$$30]  |PARTITIONED|
                                                  project ([$$30, $$29])
                                                  -- STREAM_PROJECT  |PARTITIONED|
                                                    select (function-call: algebricks:and, Args:[function-call: algebricks:lt, Args:[%0->$$33, 1994-01-01], function-call: algebricks:ge, Args:[%0->$$33, 1993-10-01], function-call: algebricks:lt, Args:[%0->$$33, 1994-01-01]])
                                                    -- STREAM_SELECT  |PARTITIONED|
                                                      exchange 
                                                      -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
                                                        data-scan [$$33, $$29, $$30]<-[$$29, $$30, $$31, $$32, $$33, $$34, $$35, $$36, $$37] <- default.orders
                                                        -- DATASOURCE_SCAN  |PARTITIONED|
                                                          exchange 
                                                          -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
                                                            empty-tuple-source
                                                            -- EMPTY_TUPLE_SOURCE  |PARTITIONED|
                                                exchange 
                                                -- HASH_PARTITION_EXCHANGE [$$21]  |PARTITIONED|
                                                  data-scan [$$21, $$22, $$23, $$24, $$25, $$26, $$28]<-[$$21, $$22, $$23, $$24, $$25, $$26, $$27, $$28] <- default.customer
                                                  -- DATASOURCE_SCAN  |PARTITIONED|
                                                    exchange 
                                                    -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
                                                      empty-tuple-source
                                                      -- EMPTY_TUPLE_SOURCE  |PARTITIONED|