Towards collaborative data reduction in stream-processing systems. (22nd June 2009)