{"status":"ok","message-type":"work","message-version":"1.0.0","message":{"indexed":{"date-parts":[[2025,10,12]],"date-time":"2025-10-12T04:05:03Z","timestamp":1760241903961,"version":"build-2065373602"},"reference-count":47,"publisher":"MDPI AG","issue":"11","license":[{"start":{"date-parts":[[2018,11,2]],"date-time":"2018-11-02T00:00:00Z","timestamp":1541116800000},"content-version":"vor","delay-in-days":0,"URL":"https:\/\/creativecommons.org\/licenses\/by\/4.0\/"}],"funder":[{"name":"the JSPS KAKENHI Grant","award":["15H02705"],"award-info":[{"award-number":["15H02705"]}]},{"DOI":"10.13039\/501100001809","name":"the National Natural Science Foundation of China","doi-asserted-by":"publisher","award":["61672435, 61702427, 61702426"],"award-info":[{"award-number":["61672435, 61702427, 61702426"]}],"id":[{"id":"10.13039\/501100001809","id-type":"DOI","asserted-by":"publisher"}]},{"name":"the 1000-Plan of Chongqing by Southwest University","award":["SWU116007"],"award-info":[{"award-number":["SWU116007"]}]}],"content-domain":{"domain":[],"crossmark-restriction":false},"short-container-title":["Sensors"],"abstract":"<jats:p>Efficient matching of incoming events of data streams to persistent queries is fundamental to event stream processing systems in wireless sensor networks. These applications require dealing with high volume and continuous data streams with fast processing time on distributed complex event processing (CEP) systems. Therefore, a well-managed parallel processing technique is needed for improving the performance of the system. However, the specific properties of pattern operators in the CEP systems increase the difficulties of the parallel processing problem. To address these issues, a parallelization model and an adaptive parallel processing strategy are proposed for the complex event processing by introducing a histogram and utilizing the probability and queue theory. The proposed strategy can estimate the optimal event splitting policy, which can suit the most recent workload conditions such that the selected policy has the least expected waiting time for further processing of the arriving events. The proposed strategy can keep the CEP system running fast under the variation of the time window sizes of operators and the input rates of streams. Finally, the utility of our work is demonstrated through the experiments on the StreamBase system.<\/jats:p>","DOI":"10.3390\/s18113732","type":"journal-article","created":{"date-parts":[[2018,11,5]],"date-time":"2018-11-05T04:26:39Z","timestamp":1541391999000},"page":"3732","update-policy":"https:\/\/doi.org\/10.3390\/mdpi_crossmark_policy","source":"Crossref","is-referenced-by-count":6,"title":["An Adaptive Parallel Processing Strategy for Complex Event Processing Systems over Data Streams in Wireless Sensor Networks"],"prefix":"10.3390","volume":"18","author":[{"ORCID":"https:\/\/orcid.org\/0000-0002-6303-895X","authenticated-orcid":false,"given":"Fuyuan","family":"Xiao","sequence":"first","affiliation":[{"name":"School of Computer and Information Science, Southwest University, No.2 Tiansheng Road, BeiBei District, Chongqing 400715, China"}],"role":[{"role":"author","vocabulary":"crossref"}]},{"ORCID":"https:\/\/orcid.org\/0000-0003-0861-849X","authenticated-orcid":false,"given":"Masayoshi","family":"Aritsugi","sequence":"additional","affiliation":[{"name":"Big Data Science and Technology, Division of Informatics and Energy, Faculty of Advanced Science and Technology, Kumamoto University, 2-39-1 Kurokami, Chuo-ku, Kumamoto 860-8555, Japan"}],"role":[{"role":"author","vocabulary":"crossref"}]}],"member":"1968","published-online":{"date-parts":[[2018,11,2]]},"reference":[{"key":"ref_1","doi-asserted-by":"crossref","first-page":"207","DOI":"10.1007\/s11042-009-0414-5","article-title":"A scalable and adaptive video streaming framework over multiple paths","volume":"47","author":"Lee","year":"2010","journal-title":"Multimed. Tools Appl."},{"key":"ref_2","first-page":"445","article-title":"Perceptual quality based error control for scalable on-demand streaming in next-generation wireless networks","volume":"52","author":"Ding","year":"2013","journal-title":"Telecommun. Syst."},{"key":"ref_3","doi-asserted-by":"crossref","first-page":"811","DOI":"10.1016\/j.asoc.2017.05.020","article-title":"An effective handling of secure data stream in IoT","volume":"68","author":"Jang","year":"2018","journal-title":"Appl. Soft Comput."},{"key":"ref_4","doi-asserted-by":"crossref","first-page":"1040","DOI":"10.1016\/S1665-6423(14)71664-5","article-title":"Recommendation-aware smartphone sensing system","volume":"12","author":"Chen","year":"2014","journal-title":"J. Appl. Res. Technol."},{"key":"ref_5","doi-asserted-by":"crossref","first-page":"445","DOI":"10.1016\/j.eswa.2013.07.070","article-title":"A model-driven approach for facilitating user-friendly design of complex event patterns","volume":"41","author":"Ortiz","year":"2014","journal-title":"Expert Syst. Appl."},{"key":"ref_6","doi-asserted-by":"crossref","first-page":"7425","DOI":"10.1109\/ACCESS.2016.2621718","article-title":"Complex event processing modeling by prioritized colored Petri nets","volume":"4","author":"Valero","year":"2016","journal-title":"IEEE Access"},{"key":"ref_7","doi-asserted-by":"crossref","first-page":"15","DOI":"10.1145\/2187671.2187677","article-title":"Processing flows of information: From data stream to complex event processing","volume":"44","author":"Cugola","year":"2012","journal-title":"ACM Comput. Surv. (CSUR)"},{"unstructured":"(2017, September 12). SASE. Available online: http:\/\/avid.cs.umass.edu\/sase\/.","key":"ref_8"},{"unstructured":"(2017, September 12). Cayuga. Available online: http:\/\/www.cs.cornell.edu\/bigreddata\/cayuga\/.","key":"ref_9"},{"unstructured":"(2017, September 12). PIPES. Available online: http:\/\/dbs.mathematik.uni-marburg.de\/Home\/Research\/Projects\/PIPES\/.","key":"ref_10"},{"unstructured":"(2017, September 12). Coral8. Available online: http:\/\/www.complexevents.com\/coral8-inc\/.","key":"ref_11"},{"unstructured":"(2017, September 12). Streambase. Available online: https:\/\/www.tibco.com\/products\/tibco-streambase.","key":"ref_12"},{"unstructured":"(2017, September 12). Oracle CEP. Available online: https:\/\/www.oracle.com\/technetwork\/middleware\/complex-event-processing\/overview\/index.html.","key":"ref_13"},{"unstructured":"(2017, September 12). CEP for Hospital. Available online: https:\/\/stanfordhealthcare.org\/search-results.clinics.html.","key":"ref_14"},{"key":"ref_15","doi-asserted-by":"crossref","first-page":"8095","DOI":"10.1016\/j.eswa.2015.06.045","article-title":"ModeL4CEP: Graphical domain-specific modeling languages for CEP domains and event patterns","volume":"42","author":"Ortiz","year":"2015","journal-title":"Expert Syst. Appl."},{"key":"ref_16","doi-asserted-by":"crossref","first-page":"463","DOI":"10.1016\/j.eswa.2015.11.005","article-title":"i-RM: An intelligent risk management framework for context-aware ubiquitous cold chain logistics","volume":"46","author":"Kim","year":"2016","journal-title":"Expert Syst. Appl."},{"key":"ref_17","doi-asserted-by":"crossref","first-page":"56","DOI":"10.1016\/j.artmed.2016.08.002","article-title":"Efficient processing of multiple nested event pattern queries over multi-dimensional event streams based on a triaxial hierarchical model","volume":"72","author":"Xiao","year":"2016","journal-title":"Artif. Intell. Med."},{"key":"ref_18","doi-asserted-by":"crossref","first-page":"93","DOI":"10.1007\/s10619-010-7066-3","article-title":"Parallel processing of continuous queries over data streams","volume":"28","author":"Safaei","year":"2010","journal-title":"Distrib. Parallel Databases"},{"key":"ref_19","doi-asserted-by":"crossref","first-page":"188","DOI":"10.14778\/1453856.1453882","article-title":"Parallelizing query optimization","volume":"1","author":"Han","year":"2008","journal-title":"Proc. VLDB Endow."},{"doi-asserted-by":"crossref","unstructured":"Hirzel, M. (2012, January 16\u201320). Partition and compose: Parallel complex event processing. Proceedings of the 6th ACM International Conference on Distributed Event-Based Systems, Berlin, Germany.","key":"ref_20","DOI":"10.1145\/2335484.2335506"},{"doi-asserted-by":"crossref","unstructured":"Johnson, T., Muthukrishnan, M.S., Shkapenyuk, V., and Spatscheck, O. (2008, January 9\u201312). Query-aware partitioning for monitoring massive network data streams. Proceedings of the 24th International Conference on Data Engineering, Vancouver, BC, Canada.","key":"ref_21","DOI":"10.1109\/ICDE.2008.4497612"},{"unstructured":"Liu, B., and Rundensteiner, E.A. (September, January 30). Revisiting pipelined parallelism in multi-join query processing. Proceedings of the 31st International Conference on Very Large Data Bases, Trondheim, Norway.","key":"ref_22"},{"key":"ref_23","doi-asserted-by":"crossref","first-page":"1265","DOI":"10.14778\/1454159.1454166","article-title":"SCOPE: Easy and efficient parallel processing of massive data sets","volume":"1","author":"Chaiken","year":"2008","journal-title":"Proc. VLDB Endow."},{"doi-asserted-by":"crossref","unstructured":"Upadhyaya, P., Kwon, Y., and Balazinska, M. (2011, January 12\u201316). A latency and fault-tolerance optimizer for online parallel query plans. Proceedings of the ACM SIGMOD International Conference on Management of Data, Athens, Greece.","key":"ref_24","DOI":"10.1145\/1989323.1989350"},{"key":"ref_25","doi-asserted-by":"crossref","first-page":"619","DOI":"10.1007\/s11227-011-0621-5","article-title":"Dispatching stream operators in parallel execution of continuous queries","volume":"61","author":"Safaei","year":"2012","journal-title":"J. Supercomput."},{"doi-asserted-by":"crossref","unstructured":"Brenna, L., Gehrke, J., Hong, M., and Johansen, D. (2009, January 6\u20139). Distributed event stream processing with non-deterministic finite automata. Proceedings of the Third ACM International Conference on Distributed Event-Based Systems, Nashville, TN, USA.","key":"ref_26","DOI":"10.1145\/1619258.1619263"},{"key":"ref_27","doi-asserted-by":"crossref","first-page":"66","DOI":"10.14778\/1453856.1453869","article-title":"Plan-based complex event detection across distributed sources","volume":"1","author":"Akdere","year":"2008","journal-title":"Proc. VLDB Endow."},{"doi-asserted-by":"crossref","unstructured":"Xiao, F., and Aritsugi, M. (2013, January 22\u201326). Nested pattern queries processing optimization over multi-dimensional event streams. Proceedings of the 37th Annual Computer Software and Applications Conference, Kyoto, Japan.","key":"ref_28","DOI":"10.1109\/COMPSAC.2013.14"},{"unstructured":"Carney, D., \u00c7etintemel, U., Cherniack, M., Convey, C., Lee, S., Seidman, G., Stonebraker, M., Tatbul, N., and Zdonik, S. (, January 20\u201323August). Monitoring streams: A new class of data management applications. Proceedings of the 28th International Conference on Very Large Data Bases, Hong Kong, China.","key":"ref_29"},{"key":"ref_30","doi-asserted-by":"crossref","first-page":"1062","DOI":"10.1587\/transinf.E95.D.1062","article-title":"Economical and fault-tolerant load balancing in distributed stream processing systems","volume":"95","author":"Xiao","year":"2012","journal-title":"IEICE Trans. Inf. Syst."},{"doi-asserted-by":"crossref","unstructured":"Suhothayan, S., Gajasinghe, K., Loku Narangoda, I., Chaturanga, S., Perera, S., and Nanayakkara, V. (2011, January 18). Siddhi: A second look at complex event processing architectures. Proceedings of the 2011 ACM Workshop on Gateway Computing Environments, Seattle, WA, USA.","key":"ref_31","DOI":"10.1145\/2110486.2110493"},{"doi-asserted-by":"crossref","unstructured":"Wu, S., Kumar, V., Wu, K.L., and Ooi, B.C. Parallelizing stateful operators in a distributed stream processing system: How, should you and how much? In Proceedings of the 6th ACM International Conference on Distributed Event-Based Systems, Berlin, Germany, 16\u201320 July 2012; pp.","key":"ref_32","DOI":"10.1145\/2335484.2335515"},{"unstructured":"Balkesen, C., Dindar, N., Wetter, M., and Tatbul, N. (July, January 29). RIP: Run-based intra-query parallelism for scalable complex event processing. Proceedings of the 7th ACM International Conference on Distributed Event-based Systems, Arlington, TX, USA.","key":"ref_33"},{"unstructured":"Brito, A., Martin, A., Knauth, T., Creutz, S., Becker, D., Weigert, S., and Fetzer, C. (December, January 29). Scalable and low-latency data processing with stream mapreduce. Proceedings of the IEEE Third International Conference on Cloud Computing Technology and Science (CloudCom), Athens, Greece.","key":"ref_34"},{"doi-asserted-by":"crossref","unstructured":"Schneider, S., Hirzel, M., Gedik, B., and Wu, K.L. (2012, January 19\u201323). Auto-parallelizing stateful distributed streaming applications. Proceedings of the 21st international conference on Parallel Architectures and Compilation Techniques, Minneapolis, MN, USA.","key":"ref_35","DOI":"10.1145\/2370816.2370826"},{"key":"ref_36","doi-asserted-by":"crossref","first-page":"382","DOI":"10.1007\/s10766-016-0413-x","article-title":"Parallel patterns for window-based stateful operators on data streams: An algorithmic skeleton approach","volume":"45","author":"Mencagli","year":"2017","journal-title":"Int. J. Parallel Program."},{"doi-asserted-by":"crossref","unstructured":"Liu, M., Rundensteiner, E., Greenfield, K., Gupta, C., Wang, S., Ari, I., and Mehta, A. (2011, January 12\u201316). E-Cube: Multi-dimensional event sequence analysis using hierarchical pattern query sharing. Proceedings of the ACM SIGMOD International Conference on Management of Data, Athens, Greece.","key":"ref_37","DOI":"10.1145\/1989323.1989416"},{"doi-asserted-by":"crossref","unstructured":"Liu, M., Rundensteiner, E., Dougherty, D., Gupta, C., Wang, S., Ari, I., and Mehta, A. (2011, January 11\u201316). High-performance nested CEP query processing over event streams. Proceedings of the 27th International Conference on Data Engineering, Hannover, Germany.","key":"ref_38","DOI":"10.1109\/ICDE.2011.5767839"},{"doi-asserted-by":"crossref","unstructured":"Dattatreya, G.R. (2008). Performance Analysis of Queuing and Computer Networks, CRC Press.","key":"ref_39","DOI":"10.1201\/9781584889878"},{"unstructured":"Newell, C. (2013). Applications of Queueing Theory, Springer Science & Business Media.","key":"ref_40"},{"unstructured":"Saaty, T.L. (1961). Elements of Queueing Theory: With Applications, McGraw-Hill.","key":"ref_41"},{"key":"ref_42","doi-asserted-by":"crossref","first-page":"343","DOI":"10.1016\/j.future.2016.05.025","article-title":"A coral-reefs and game theory-based approach for optimizing elastic cloud resource allocation","volume":"78","author":"Ficco","year":"2018","journal-title":"Future Gen. Comput. Syst."},{"key":"ref_43","doi-asserted-by":"crossref","first-page":"975","DOI":"10.1016\/j.future.2017.08.051","article-title":"Aging-related performance anomalies in the apache storm stream processing system","volume":"86","author":"Ficco","year":"2018","journal-title":"Future Gen. Comput. Syst."},{"doi-asserted-by":"crossref","unstructured":"Yin, L., Deng, X., and Deng, Y. (2018). The negation of a basic probability assignment. IEEE Trans. Fuzzy Syst.","key":"ref_44","DOI":"10.1109\/TFUZZ.2018.2871756"},{"key":"ref_45","doi-asserted-by":"crossref","first-page":"1745","DOI":"10.1002\/int.21995","article-title":"Generating Z-number based on OWA weights using maximum entropy","volume":"33","author":"Kang","year":"2018","journal-title":"Int. J. Intell. Syst."},{"doi-asserted-by":"crossref","unstructured":"Fei, L., and Deng, Y. (2018). A new divergence measure for basic probability assignment and its applications in extremely uncertain environments. Int. J. Intell. Syst.","key":"ref_46","DOI":"10.1002\/int.22066"},{"doi-asserted-by":"crossref","unstructured":"Zhang, W., and Deng, Y. (2018). Combining conflicting evidence using the DEMATEL method. Soft Comput.","key":"ref_47","DOI":"10.1007\/s00500-018-3455-8"}],"container-title":["Sensors"],"original-title":[],"language":"en","link":[{"URL":"https:\/\/www.mdpi.com\/1424-8220\/18\/11\/3732\/pdf","content-type":"unspecified","content-version":"vor","intended-application":"similarity-checking"}],"deposited":{"date-parts":[[2025,10,11]],"date-time":"2025-10-11T15:27:35Z","timestamp":1760196455000},"score":1,"resource":{"primary":{"URL":"https:\/\/www.mdpi.com\/1424-8220\/18\/11\/3732"}},"subtitle":[],"short-title":[],"issued":{"date-parts":[[2018,11,2]]},"references-count":47,"journal-issue":{"issue":"11","published-online":{"date-parts":[[2018,11]]}},"alternative-id":["s18113732"],"URL":"https:\/\/doi.org\/10.3390\/s18113732","relation":{},"ISSN":["1424-8220"],"issn-type":[{"type":"electronic","value":"1424-8220"}],"subject":[],"published":{"date-parts":[[2018,11,2]]}}}