Real-Time Stream Processing for Internet of Things