Support for Adaptive and Distributed Deployment of CEP Continuous Queries for the IoMT


The current dissemination of IoT increases the deployment of stream processing solutions for monitoring and controlling elements of the real-world. One of those solutions is Complex Event Processing (CEP), and to handle the high volume, velocity and volatility of data streams from IoT sensors the CEP pipeline should be distributed, preferably having CEP operators both in the cloud/cluster and in edge devices. In this paper, we present a model for a distributed CEP platform and an implementation of this model called Global CEP Manager (GCM). GCM is a service of the ContextNet middleware that supports the deployment and dynamic rearrangement of CEP queries to CEP engines executing in the cloud and in M-Hubs, that are ContextNet’s mobile edge devices.

Palavras-chave: Stream Processing, Complex Event Processing, Internet of Things


Balazinska, M., Balakrishnan, H., Madden, S., and Stonebraker, M. (2005). Fault-tolerance in the borealis distributed stream processing system. In Proceedings of the 2005 ACM SIGMOD International Conference on Management of Data, SIGMOD ’05, pages 13–24, New York, NY, USA. ACM.

Carney, D., Çetintemel, U., Cherniack, M., Convey, C., Lee, S., Seidman, G., Stonebraker, M., Tatbul, N., and Zdonik, S. (2002). Monitoring streams: A new class of data management applications. In Proceedings of the 28th International Conference on Very Large Data Bases, VLDB ’02, pages 215–226. VLDB Endowment.

Cugola, G. and Margara, A. (2012). Processing flows of information: From data stream to complex event processing. ACM Comput. Surv., 44(3):15:1–15:62.

Endler, M. and e Silva, F. S. (2018). Past, present and future of the contextnet iomt middleware. Open Journal of Internet Of Things (OJIOT), 4(1):7–23.

Etzion, O., Niblett, P., and Luckham, D. C. (2011). Event processing in action. Manning Greenwich.

Jayasekara, S., Kannangara, S., Dahanayakage, T., Ranawaka, I., Perera, S., and Nanayakkara, V. (2015). Wihidum: Distributed complex event processing. Journal of Parallel and Distributed Computing, 79-80:42 – 51. Special Issue on Scalable Systems for Big Data Management and Analytics.

Luckham, D. (2002). The power of events, volume 204. Addison-Wesley Reading.

Luckham, D. C. (2011). Event processing for business: organizing the real-time enterprise. John Wiley & Sons.

Pietzuch, P. R., Shand, B., and Bacon, J. (2003). A framework for event composition in distributed systems. In Proceedings of the ACM/IFIP/USENIX 2003 International Conference on Middleware, Middleware ’03, pages 62–82, New York, NY, USA. Springer-Verlag New York, Inc.

Rios, L. T., Endler, M., and Colcher, S. (2016). An energy-aware iot gateway, with continuous processing of sensor data. In SBRC2016, XXXIV Simpósio Brasileiro de Redes de Computadores e Sistemas Distribuı́dos - SBRC2016, Salvador, Brasil.

Starks, F. and Plagemann, T. P. (2015). Operator placement for efficient distributed complex event processing in manets. In 2015 IEEE 11th International Conference on Wireless and Mobile Computing, Networking and Communications (WiMob), pages 83–90.
MAGALHÃES, Fernando Benedito Veras; SILVA, Francisco José da Silva e; ENDLER, Markus. Support for Adaptive and Distributed Deployment of CEP Continuous Queries for the IoMT. In: SIMPÓSIO BRASILEIRO DE REDES DE COMPUTADORES E SISTEMAS DISTRIBUÍDOS (SBRC), 38. , 2020, Rio de Janeiro. Anais [...]. Porto Alegre: Sociedade Brasileira de Computação, 2020 . p. 99-112. ISSN 2177-9384. DOI: