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|