A Cloud Based Architecture for Distributed Real Time Processing of Continuous Queries

Gökalp, Mert Onuralp
The technological advancements in Internet of Things (IoT) domain have enabled us to reshape the physical world through smart devices, sensors and actuators. The data collected by IoT devices has become a valuable asset to extract knowledge about the environment and other nearby devices. Existing IoT applications mostly store collected data in a central server and allow users to query stored data to notice and react to changes in the environment. Usually cloud and big data technologies are utilized in those applications for scalability. Nevertheless, the responsiveness of such IoT applications is limited due to the use of polling based queries. In this thesis, we primarily focus on the problem of specifying a generic and scalable architecture to process a multitude of continuous queries in real time, respond to events and notify users in a timely manner. For this purpose, we propose a data-flow based query definition model to allow users create flexible queries. We devise a centrally managed distributed infrastructure based on the state of the art big data technologies to execute the continuous queries over streaming data rather than storing and frequently querying the data collected. A prototype has been implemented to demonstrate the applicability and to evaluate the scalability of the proposed approach.
Citation Formats
M. O. Gökalp, “A Cloud Based Architecture for Distributed Real Time Processing of Continuous Queries,” M.S. - Master of Science, Middle East Technical University, 2015.