write [%0->$$1, %0->$$2, %0->$$3, %0->$$4]
-- SINK_WRITE  |PARTITIONED|
  select (function-call: algebricks:lt, Args:[function-call: hive:org.apache.hadoop.hive.ql.udf.UDFOPMultiply, Args:[%0->$$1, 2], 20])
  -- STREAM_SELECT  |PARTITIONED|
    exchange 
    -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
      data-scan [$$1, $$2, $$3, $$4]<-[$$1, $$2, $$3, $$4, $$5, $$6, $$7] <- default.supplier
      -- DATASOURCE_SCAN  |PARTITIONED|
        exchange 
        -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
          empty-tuple-source
          -- EMPTY_TUPLE_SOURCE  |PARTITIONED|
write [%0->$$1, %0->$$9, %0->$$10, %0->$$11]
-- SINK_WRITE  |PARTITIONED|
  project ([$$1, $$9, $$10, $$11])
  -- STREAM_PROJECT  |PARTITIONED|
    exchange 
    -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
      join (function-call: algebricks:eq, Args:[%0->$$5, %0->$$1])
      -- HYBRID_HASH_JOIN [$$5][$$1]  |PARTITIONED|
        exchange 
        -- HASH_PARTITION_EXCHANGE [$$5]  |PARTITIONED|
          data-scan [$$5, $$9, $$10, $$11]<-[$$5, $$6, $$7, $$8, $$9, $$10, $$11] <- default.supplier
          -- 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]<-[$$1, $$2, $$3, $$4] <- default.result
          -- DATASOURCE_SCAN  |PARTITIONED|
            exchange 
            -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
              empty-tuple-source
              -- EMPTY_TUPLE_SOURCE  |PARTITIONED|