Design of a Distributed Stream Processing Engine

I'm one of the core devs and happy to answer any questions as well.