This seems conceptually similar to http://www.cascading.org/ (at least looking the code examples: http://www.cascading.org/1.1/userguide/html/ch02.html ).
Stream processing jobs can be massaged to fit into the MapReduce paradigm, but S4 provides a more natural solution.