Distributed Stream Processing - View it on GitHub