[DanielRibeiro]

Seems very much like Percolator from google: http://www.infoq.com/news/2010/10/google-percolator

[schumihan]

I don't think so. Percolator does not support stream operators, and it supports transaction semantic. Streaming process engine like s4 will never handle the race conditions brought by multiple writers.