An open source stream processing engine for IoT