A simple dsl to build stream based processing of data. Think ETL