{"status":"ok","message-type":"work","message-version":"1.0.0","message":{"indexed":{"date-parts":[[2026,5,14]],"date-time":"2026-05-14T06:37:32Z","timestamp":1778740652096,"version":"3.51.4"},"reference-count":37,"publisher":"SAGE Publications","issue":"8","license":[{"start":{"date-parts":[[2017,8,1]],"date-time":"2017-08-01T00:00:00Z","timestamp":1501545600000},"content-version":"tdm","delay-in-days":0,"URL":"http:\/\/journals.sagepub.com\/page\/policies\/text-and-data-mining-license"}],"content-domain":{"domain":["journals.sagepub.com"],"crossmark-restriction":true},"short-container-title":["International Journal of Distributed Sensor Networks"],"published-print":{"date-parts":[[2017,8]]},"abstract":"<jats:p> Sensor network\u2013based application has gained increasing attention where data streams gathered from distributed sensors need to be processed and analyzed with timely responses. Distributed complex event processing is an effective technology to handle these data streams by matching of incoming events to persistent pattern queries. Therefore, a well-managed parallel processing scheme is required to improve both system performance and the quality-of-service guarantees of the system. However, the specific properties of pattern operators increase the difficulties of implementing parallel processing. To address this issue, a new parallelization model and three parallel processing strategies are proposed for distributed complex event processing systems. The effects of temporal constraints, for example, sliding windows, are included in the new parallelization model to enable the processing load for the overlap between windows of a batch induced by each input event to be shared by the downstream machines to avoid events that may result in wrong decisions. The proposed parallel strategies can keep the complex event processing system working stably and continuously during the elapsed time. Finally, the application of our work is demonstrated using experiments on the StreamBase system regardless of the increased input rate of the stream or the increased time window size of the operator. <\/jats:p>","DOI":"10.1177\/1550147717728626","type":"journal-article","created":{"date-parts":[[2017,8,31]],"date-time":"2017-08-31T12:26:37Z","timestamp":1504182397000},"page":"155014771772862","update-policy":"https:\/\/doi.org\/10.1177\/sage-journals-update-policy","source":"Crossref","is-referenced-by-count":30,"title":["New parallel processing strategies in complex event processing systems with data streams"],"prefix":"10.1177","volume":"13","author":[{"given":"Fuyuan","family":"Xiao","sequence":"first","affiliation":[{"name":"School of Computer and Information Science, Southwest University, Chongqing, China"}],"role":[{"role":"author","vocabulary":"crossref"}]},{"given":"Cheng","family":"Zhan","sequence":"additional","affiliation":[{"name":"School of Computer and Information Science, Southwest University, Chongqing, China"}],"role":[{"role":"author","vocabulary":"crossref"}]},{"given":"Hong","family":"Lai","sequence":"additional","affiliation":[{"name":"School of Computer and Information Science, Southwest University, Chongqing, China"}],"role":[{"role":"author","vocabulary":"crossref"}]},{"given":"Li","family":"Tao","sequence":"additional","affiliation":[{"name":"School of Computer and Information Science, Southwest University, Chongqing, China"}],"role":[{"role":"author","vocabulary":"crossref"}]},{"given":"Zhiguo","family":"Qu","sequence":"additional","affiliation":[{"name":"School of Computer & Software, Nanjing University of Information Science & Technology, Nanjing, China"}],"role":[{"role":"author","vocabulary":"crossref"}]}],"member":"179","published-online":{"date-parts":[[2017,8,31]]},"reference":[{"issue":"2","key":"bibr1-1550147717728626","first-page":"169","volume":"38","author":"Bhargavi R","year":"2013","journal-title":"Sadhana"},{"key":"bibr3-1550147717728626","doi-asserted-by":"publisher","DOI":"10.1007\/s00778-003-0095-z"},{"issue":"1","key":"bibr4-1550147717728626","first-page":"3","volume":"33","author":"Balazinska M","year":"2008","journal-title":"ACM T Database Syst"},{"key":"bibr6-1550147717728626","first-page":"176","volume-title":"Proceedings of the 23rd international conference on data engineering (ICDE 2007)","author":"Hwang J-H"},{"key":"bibr7-1550147717728626","first-page":"827","volume-title":"Proceedings of the ACM SIGMOD international conference on management of data (SIGMOD 2004)","author":"Shah MA"},{"key":"bibr10-1550147717728626","first-page":"889","volume-title":"Proceedings of the ACM SIGMOD international conference on management of data (SIGMOD 2011)","author":"Liu M"},{"key":"bibr11-1550147717728626","first-page":"193","volume-title":"Proceedings of the ACM SIGMOD international conference on management of data (SIGMOD 2009)","author":"Mei Y"},{"key":"bibr12-1550147717728626","first-page":"407","volume-title":"Proceedings of the ACM SIGMOD international conference on management of data (SIGMOD 2006)","author":"Wu E"},{"key":"bibr13-1550147717728626","doi-asserted-by":"publisher","DOI":"10.14778\/1453856.1453869"},{"key":"bibr14-1550147717728626","first-page":"147","volume-title":"Proceedings of the ACM SIGMOD international conference on management of data (SIGMOD 2008)","author":"Agrawal J"},{"key":"bibr15-1550147717728626","first-page":"123","volume-title":"Proceedings of the 27th international conference on data engineering (ICDE 2011)","author":"Liu M"},{"key":"bibr16-1550147717728626","doi-asserted-by":"publisher","DOI":"10.1145\/2187671.2187677"},{"key":"bibr24-1550147717728626","doi-asserted-by":"publisher","DOI":"10.1109\/TITS.2012.2186127"},{"key":"bibr25-1550147717728626","doi-asserted-by":"publisher","DOI":"10.1016\/j.mcm.2011.09.017"},{"key":"bibr26-1550147717728626","doi-asserted-by":"publisher","DOI":"10.1016\/j.jpdc.2011.11.002"},{"issue":"1","key":"bibr27-1550147717728626","first-page":"6","volume":"14","author":"Ottenw\u00e4lder B","year":"2014","journal-title":"ACM T Internet Techn"},{"key":"bibr28-1550147717728626","doi-asserted-by":"publisher","DOI":"10.1007\/s10619-010-7066-3"},{"key":"bibr29-1550147717728626","doi-asserted-by":"publisher","DOI":"10.14778\/1453856.1453882"},{"key":"bibr30-1550147717728626","first-page":"191","volume-title":"Proceedings of the 6th ACM international conference on distributed event-based systems (DEBS 2012)","author":"Hirzel M"},{"key":"bibr31-1550147717728626","first-page":"278","volume-title":"Proceedings of the 6th ACM international conference on distributed event-based systems (DEBS 2012)","author":"Wu S"},{"key":"bibr32-1550147717728626","first-page":"1135","volume-title":"Proceedings of the 24th international conference on data engineering (ICDE 2008)","author":"Johnson T"},{"key":"bibr33-1550147717728626","first-page":"829","volume-title":"Proceedings of the 31st international conference on very large data bases (VLDB 2005)","author":"Liu B"},{"key":"bibr34-1550147717728626","doi-asserted-by":"publisher","DOI":"10.14778\/1454159.1454166"},{"key":"bibr35-1550147717728626","first-page":"241","volume-title":"Proceedings of the ACM SIGMOD international conference on management of data (SIGMOD 2011)","author":"Upadhyaya P"},{"key":"bibr36-1550147717728626","first-page":"53","volume-title":"Proceedings of the 21st international conference on parallel architectures and compilation techniques (PACT 2012)","author":"Schneider S"},{"key":"bibr37-1550147717728626","doi-asserted-by":"publisher","DOI":"10.1007\/s11227-011-0621-5"},{"key":"bibr38-1550147717728626","first-page":"3","volume-title":"Proceedings of the third ACM international conference on distributed event-based systems (DEBS 2009)","author":"Brenna L"},{"key":"bibr39-1550147717728626","first-page":"74","volume-title":"37th annual IEEE computer software and applications conference (COMPSAC 2013)","author":"Xiao F"},{"key":"bibr40-1550147717728626","first-page":"215","volume-title":"Proceedings of the 28th international conference on very large data bases (VLDB 2002)","author":"Carney D"},{"key":"bibr41-1550147717728626","doi-asserted-by":"publisher","DOI":"10.1587\/transinf.E95.D.1062"},{"key":"bibr42-1550147717728626","doi-asserted-by":"publisher","DOI":"10.1109\/JIOT.2015.2397316"},{"key":"bibr43-1550147717728626","first-page":"3","volume-title":"Proceedings of the 7th ACM international conference on distributed event-based systems","author":"Balkesen C"},{"key":"bibr44-1550147717728626","doi-asserted-by":"publisher","DOI":"10.1016\/j.jss.2016.06.011"},{"key":"bibr45-1550147717728626","doi-asserted-by":"publisher","DOI":"10.1016\/j.nucengdes.2016.12.001"},{"key":"bibr46-1550147717728626","doi-asserted-by":"publisher","DOI":"10.1016\/j.ssci.2016.06.014"},{"key":"bibr47-1550147717728626","doi-asserted-by":"publisher","DOI":"10.1142\/S0218488516500379"},{"key":"bibr48-1550147717728626","doi-asserted-by":"publisher","DOI":"10.1177\/155014773218784"}],"container-title":["International Journal of Distributed Sensor Networks"],"original-title":[],"language":"en","link":[{"URL":"http:\/\/journals.sagepub.com\/doi\/pdf\/10.1177\/1550147717728626","content-type":"application\/pdf","content-version":"vor","intended-application":"text-mining"},{"URL":"http:\/\/journals.sagepub.com\/doi\/full-xml\/10.1177\/1550147717728626","content-type":"application\/xml","content-version":"vor","intended-application":"text-mining"},{"URL":"http:\/\/journals.sagepub.com\/doi\/pdf\/10.1177\/1550147717728626","content-type":"unspecified","content-version":"vor","intended-application":"similarity-checking"}],"deposited":{"date-parts":[[2021,1,5]],"date-time":"2021-01-05T02:53:13Z","timestamp":1609815193000},"score":1,"resource":{"primary":{"URL":"http:\/\/journals.sagepub.com\/doi\/10.1177\/1550147717728626"}},"subtitle":[],"short-title":[],"issued":{"date-parts":[[2017,8]]},"references-count":37,"journal-issue":{"issue":"8","published-print":{"date-parts":[[2017,8]]}},"alternative-id":["10.1177\/1550147717728626"],"URL":"https:\/\/doi.org\/10.1177\/1550147717728626","relation":{},"ISSN":["1550-1477","1550-1477"],"issn-type":[{"value":"1550-1477","type":"print"},{"value":"1550-1477","type":"electronic"}],"subject":[],"published":{"date-parts":[[2017,8]]}}}