Lightweight Distributed Stream Processor