Boris Koldehofe
Beate Ottenwälder
ABSTRACT
Up to now, correlations in complex event processing (CEP) systems are detected by a well defined set of operators, whose configuration is determined ahead of deployment time. Although CEP operators involve location specific attributes, state of the art systems are heavily constrained in detecting situations where the interest in a situation changes depending on the consumer's location, e. g., with the movement of mobile devices.
This paper adopts the concept of range queries to CEP systems. We propose a mobility-aware event delivery semantics and present a corresponding execution model, which accounts for mobility driven selection of primary event streams to the CEP system. By utilizing the properties of this execution model, we derive an algorithm that establishes low cost and coordinated reconfiguration of CEP operators in a distributed system. The algorithm minimizes the amount of information that needs to be streamed between operators and avoids additional delays as a result of a reconfiguration of CEP operators. We present an analysis of the algorithm's properties and evaluate the efficiency of the proposed reconfiguration algorithm.
- http://www.b30-oberschwaben.de/html/vergleiche.html, February 2012.Google Scholar
- M. Akdere, U. Çetintemel, and N. Tatbul. Plan-based complex event detection across distributed sources. Proc. VLDB Endow., 1:66--77, August 2008. Google ScholarDigital Library
- A. Arasu, S. Babu, and J. Widom. The cql continuous query language: semantic foundations and query execution. The VLDB Journal, 15:121--142, June 2006. Google ScholarDigital Library
- M. Behrisch, L. Bieker, J. Erdmann, and D. Krajzewicz. Sumo - simulation of urban mobility: An overview. In SIMUL 2011, The Third International Conference on Advances in System Simulation, pages 63--68, Barcelona, Spain, October 2011.Google Scholar
- A. Benzing, B. Koldehofe, and K. Rothermel. Efficient support for multi-resolution queries in global sensor networks. In Proceedings of the 5th International Conference on Communication System Software and Middleware, COMSWARE '11, pages 11:1--11:12, New York, NY, USA, 2011. ACM. Google ScholarDigital Library
- S. Chakravarthy and D. Mishra. Snoop: An expressive event specification language for active databases. Data & Knowledge Engineering, 14(1):1--26, 1994. Google ScholarDigital Library
- M. Cheema, L. Brankovic, X. Lin, W. Zhang, and W. Wang. Multi-guarded safe zone: An effective technique to monitor moving circular range queries. In Data Engineering (ICDE), 2010 IEEE 26th International Conference on, pages 189--200, march 2010.Google ScholarCross Ref
- T. Do, K. Hua, and C.-S. Lin. Extrange: Continuous moving range queries in mobile peer-to-peer networks. In Mobile Data Management: Systems, Services and Middleware, 2009. MDM '09. Tenth International Conference on, pages 317--322, may 2009. Google ScholarDigital Library
- P. T. Eugster, P. A. Felber, R. Guerraoui, and A.-M. Kermarrec. The many faces of publish/subscribe. ACM Comput. Surv., 35(2):114--131, 2003. Google ScholarDigital Library
- T. Farrell, R. Cheng, and K. Rothermel. Energy-efficient monitoring of mobile objects with uncertainty-aware tolerances. In Proceedings of the 11th International Database Engineering and Applications Symposium, pages 129--140, Washington, DC, USA, 2007. IEEE Computer Society. Google ScholarDigital Library
- S. Gatziu and K. Dittrich. Detecting composite events in active database systems using petri nets. In Research Issues in Data Engineering, 1994. Active Database Systems. Proceedings Fourth International Workshop on, pages 2--9, 14--15 1994.Google ScholarCross Ref
- B. Gedik and L. Liu. Mobieyes: A distributed location monitoring service using moving location queries. IEEE Transactions on Mobile Computing, 5:1384--1402, 2006. Google ScholarDigital Library
- M. Haklay and P. Weber. Openstreetmap: User-generated street maps. Pervasive Computing, IEEE, 7(4):12--18, oct.--dec. 2008. Google ScholarDigital Library
- K. Jayaram, C. Jayalath, and P. Eugster. Parametric subscriptions for content-based publish/subscribe networks. In I. Gupta and C. Mascolo, editors, Middleware 2010, volume 6452 of Lecture Notes in Computer Science, pages 128--147. Springer Berlin/Heidelberg, 2010. Google ScholarDigital Library
- G. G. Koch, B. Koldehofe, and K. Rothermel. Cordies: expressive event correlation in distributed systems. In DEBS '10: Proceedings of the Fourth ACM International Conference on Distributed Event-Based Systems, pages 26--37, New York, NY, USA, 2010. ACM. Google ScholarDigital Library
- A. Leonhardi and K. Rothermel. A comparison of protocols for updating location information. Cluster Computing, 4:355--367, October 2001. Google ScholarDigital Library
- D. C. Luckham. The Power of Events: An Introduction to Complex Event Processing in Distributed Enterprise Systems. Addison-Wesley Longman Publishing Co., Inc., Boston, MA, USA, 2001. Google ScholarDigital Library
- K. Patroumpas and T. Sellis. Maintaining consistent results of continuous queries under diverse window specifications. Inf. Syst., 36:42--61, March 2011. Google ScholarDigital Library
- D. Pfoser, C. S. Jensen, and Y. Theodoridis. Novel approaches in query processing for moving object trajectories. In Proceedings of the 26th International Conference on Very Large Data Bases, VLDB '00, pages 395--406, San Francisco, CA, USA, 2000. Morgan Kaufmann Publishers Inc. Google ScholarDigital Library
- P. Pietzuch, J. Ledlie, J. Shneidman, M. Roussopoulos, M. Welsh, and M. Seltzer. Network-aware operator placement for stream-processing systems. In Proceedings of the 22nd International Conference on Data Engineering, ICDE '06, pages 49--, Washington, DC, USA, 2006. IEEE Computer Society. Google ScholarDigital Library
- P. R. Pietzuch, B. Shand, and J. Bacon. Composite event detection as a generic middleware extension. Network, IEEE, 18(1):44--55, jan/feb 2004. Google ScholarDigital Library
- S. Rizou, F. Dürr, and K. Rothermel. Solving the Multi-operator Placement Problem in Large-Scale Operator Networks. In Proceedings of the 19th International Conference on Computer Communication Networks, Zurich, August 2010. IEEE Communications Society.Google ScholarCross Ref
- B. Schilling, B. Koldehofe, U. Pletat, and K. Rothermel. Distributed heterogeneous event processing: enhancing scalability and interoperability of cep in an industrial context. In DEBS '10: Proceedings of the Fourth ACM International Conference on Distributed Event-Based Systems, pages 150--159, New York, NY, USA, 2010. ACM. Google ScholarDigital Library
- B. Schilling, B. Koldehofe, and K. Rothermel. Efficient and distributed rule placement in heavy constraint-driven event systems. In High Performance Computing and Communications (HPCC), 2011 IEEE 13th International Conference on, pages 355--364, sept. 2011. Google ScholarDigital Library
- K. Sheykh-Esmaili, T. Sanamrad, P. M. Fischer, and N. Tatbul. Changing Flights in Mid-air: A Model for Safely Modifying Continuous Queries. In ACM SIGMOD International Conference on Management of Data (SIGMOD'11), Athens, Greece, June 2011. Google ScholarDigital Library
- M. A. Tariq, G. G. Koch, B. Koldehofe, I. Khan, and K. Rothermel. Dynamic publish/subscribe to meet subscriber-defined delay and bandwidth constraints. In Proceedings of the 16th international Euro-Par conference on Parallel processing: Part I, EuroPar'10, pages 458--470, Berlin, Heidelberg, 2010. Springer-Verlag. Google ScholarDigital Library
- G. Trajcevski, H. Ding, P. Scheuermann, and I. Cruz. Bora: Routing and aggregation for distributed processing of spatio-temporal range queries. In Mobile Data Management, 2007 International Conference on, pages 36--43, may. 2007. Google ScholarDigital Library
- A. Varga. The omnet++ discrete event simulation system. In Proceedings of the European Simulation Multiconference (ESM'2001), June 2001.Google Scholar
- M. Völz, B. Koldehofe, and K. Rothermel. Supporting strong reliability for distributed complex event processing systems. In High Performance Computing and Communications (HPCC), 2011 IEEE 13th International Conference on, pages 477--486, sept. 2011. Google ScholarDigital Library
- O. Wolfson, A. P. Sistla, S. Chamberlain, and Y. Yesha. Updating and querying databases that track mobile units. Distrib. Parallel Databases, 7:257--387, July 1999. Google ScholarDigital Library
- E. Wu, Y. Diao, and S. Rizvi. High-performance complex event processing over streams. In Proceedings of the 2006 ACM SIGMOD international conference on Management of data, SIGMOD '06, pages 407--418, New York, NY, USA, 2006. ACM. Google ScholarDigital Library
- X. Xiong, H. Elmongui, X. Chai, and W. Aref. Place: A distributed spatio-temporal data stream management system for moving objects. In Mobile Data Management, 2007 International Conference on, pages 44--51, May 2007. Google ScholarDigital Library
Index Terms
- Moving range queries in distributed complex event processing
Recommendations
Complex event processing with T-REX
Several application domains involve detecting complex situations and reacting to them. This asks for a Complex Event Processing (CEP) middleware specifically designed to timely process large amounts of event notifications as they flow from the ...
Towards complex actions for complex event processing
DEBS '13: Proceedings of the 7th ACM international conference on Distributed event-based systemsComplex actions are a natural extension for complex event processing languages needed by many applications like emergency management. In particular interactions with external actuators that are common in those applications pose challenges that need to ...
Reasoning on the Efficiency of Distributed Complex Event Processing
Concurrency, Specification, and Programming: Special Issue of Selected Papers of CS&P 2018Complex event processing (CEP) evaluates queries over streams of event data to detect situations of interest. If the event data are produced by geographically distributed sources, CEP may exploit in-network processing that distributes the evaluation of a ...
Comments