write [%0->$$6, %0->$$2, %0->$$5, %0->$$1]
-- SINK_WRITE  |PARTITIONED|
  project ([$$6, $$2, $$5, $$1])
  -- STREAM_PROJECT  |PARTITIONED|
    exchange 
    -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
      join (function-call: algebricks:and, Args:[function-call: algebricks:gt, Args:[%0->$$5, %0->$$1], true])
      -- NESTED_LOOP  |PARTITIONED|
        exchange 
        -- BROADCAST_EXCHANGE  |PARTITIONED|
          data-scan [$$1, $$2]<-[$$1, $$2, $$3, $$4] <- default.nation
          -- DATASOURCE_SCAN  |PARTITIONED|
            exchange 
            -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
              empty-tuple-source
              -- EMPTY_TUPLE_SOURCE  |PARTITIONED|
        exchange 
        -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
          data-scan [$$5, $$6]<-[$$5, $$6, $$7, $$8] <- default.nation
          -- DATASOURCE_SCAN  |PARTITIONED|
            exchange 
            -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
              empty-tuple-source
              -- EMPTY_TUPLE_SOURCE  |PARTITIONED|