Run standard SQL

[jamesfer]

• create mechanisms for existing DF operators to run in streaming mode.
  • Hash join: manually accumulate the build side into the state, create lineage markers on probe side by assuming data is consumed instantly