a data stream framework