{"status":"ok","message-type":"work","message-version":"1.0.0","message":{"indexed":{"date-parts":[[2026,3,5]],"date-time":"2026-03-05T15:58:22Z","timestamp":1772726302822,"version":"3.50.1"},"reference-count":29,"publisher":"World Scientific Pub Co Pte Ltd","issue":"11n12","funder":[{"DOI":"10.13039\/501100001809","name":"National Natural Science Foundation of China","doi-asserted-by":"publisher","award":["61772334"],"award-info":[{"award-number":["61772334"]}],"id":[{"id":"10.13039\/501100001809","id-type":"DOI","asserted-by":"publisher"}]},{"name":"the National Key Research and Development Program of China","award":["2019YFB1704400"],"award-info":[{"award-number":["2019YFB1704400"]}]}],"content-domain":{"domain":[],"crossmark-restriction":false},"short-container-title":["Int. J. Soft. Eng. Knowl. Eng."],"published-print":{"date-parts":[[2022,11]]},"abstract":"<jats:p> The content-based publish\/subscribe system is an effective paradigm for implementing on-demand event distribution. Each event needs to be matched against subscriptions to identify the target subscribers. To improve the matching performance, many novel data structures have been proposed. However, the predicates contained in subscriptions are handled the same way in most existing data structures, without considering their differences in matching probability. In this paper, we propose the concept of parallel ensemble matching (PEM) based on subscription partitioning. The basic idea is that we have the right algorithm handling the right subscriptions at the right time. First of all, we design a PEM framework by classifying subscriptions according to their matching probabilities and use the proper algorithms to process each subscription category. Furthermore, to deal with high-dimensional subscriptions, we propose a fine-grained PEM (fgPEM) that exploits matching algorithms with complementary behaviors by partitioning subscriptions into sub-subscriptions. We implement the prototype of PEM and fgPEM based on two existing algorithms. The experiment results show that PEM improves the matching performance by 43%. On the basis of PEM, fgPEM further improves the performance by 31%. <\/jats:p>","DOI":"10.1142\/s0218194022500619","type":"journal-article","created":{"date-parts":[[2022,9,30]],"date-time":"2022-09-30T06:14:58Z","timestamp":1664518498000},"page":"1733-1752","source":"Crossref","is-referenced-by-count":2,"title":["Parallel Ensemble Matching Based on Subscription Partitioning for Content-Based Publish\/Subscribe Systems"],"prefix":"10.1142","volume":"32","author":[{"given":"Junshen","family":"Li","sequence":"first","affiliation":[{"name":"Shanghai Jiao Tong University, Shanghai, P. R. China"}],"role":[{"role":"author","vocabulary":"crossref"}]},{"given":"Yufeng","family":"Deng","sequence":"additional","affiliation":[{"name":"Shanghai Jiao Tong University, Shanghai, P. R. China"}],"role":[{"role":"author","vocabulary":"crossref"}]},{"ORCID":"https:\/\/orcid.org\/0000-0001-7775-1740","authenticated-orcid":false,"given":"Shiyou","family":"Qian","sequence":"additional","affiliation":[{"name":"Shanghai Jiao Tong University, Shanghai, P. R. China"}],"role":[{"role":"author","vocabulary":"crossref"}]},{"given":"Jian","family":"Cao","sequence":"additional","affiliation":[{"name":"Shanghai Jiao Tong University, Shanghai, P. R. China"}],"role":[{"role":"author","vocabulary":"crossref"}]},{"given":"Guangtao","family":"Xue","sequence":"additional","affiliation":[{"name":"Shanghai Jiao Tong University, Shanghai, P. R. China"}],"role":[{"role":"author","vocabulary":"crossref"}]}],"member":"219","published-online":{"date-parts":[[2022,10,25]]},"reference":[{"key":"S0218194022500619BIB001","first-page":"1936","volume-title":"2019 IEEE Conf. Computer Communications","author":"Qian S.","year":"2019"},{"key":"S0218194022500619BIB002","first-page":"148","volume-title":"2020 IEEE Int. Parallel and Distributed Processing Symp.","author":"Ding T.","year":"2020"},{"key":"S0218194022500619BIB003","first-page":"1","volume-title":"90th IEEE Vehicular Technology Conf.","author":"Dasanayaka N.","year":"2019"},{"issue":"3","key":"S0218194022500619BIB004","doi-asserted-by":"crossref","first-page":"332","DOI":"10.1145\/380749.380767","volume":"19","author":"Carzaniga A.","year":"2001","journal-title":"ACM Trans. Comput. Syst."},{"key":"S0218194022500619BIB005","doi-asserted-by":"publisher","DOI":"10.1145\/857076.857078"},{"issue":"4","key":"S0218194022500619BIB006","doi-asserted-by":"crossref","first-page":"855","DOI":"10.1109\/TPDS.2020.3036014","volume":"32","author":"Ding T.","year":"2021","journal-title":"IEEE Trans. Parallel Distrib. Syst."},{"issue":"6","key":"S0218194022500619BIB007","doi-asserted-by":"crossref","first-page":"1622","DOI":"10.1109\/TPDS.2014.2323262","volume":"26","author":"Qian S.","year":"2015","journal-title":"IEEE Trans. Parallel Distrib. Syst."},{"key":"S0218194022500619BIB008","first-page":"817","volume-title":"Proc. 2021 Int. Conf. Management of Data","author":"Ji S.","year":"2021"},{"key":"S0218194022500619BIB009","first-page":"637","volume-title":"Proc. ACM SIGMOD Int. Conf. Management of Data","author":"Sadoghi M.","year":"2011"},{"key":"S0218194022500619BIB010","first-page":"790","volume-title":"2011 Int. Conf. Distributed Computing Systems","author":"Zhao Y.","year":"2011"},{"issue":"8","key":"S0218194022500619BIB011","doi-asserted-by":"crossref","first-page":"613","DOI":"10.14778\/2732296.2732298","volume":"7","author":"Zhang D.","year":"2014","journal-title":"Proc. VLDB Endow."},{"key":"S0218194022500619BIB012","first-page":"2058","volume-title":"2014 IEEE Conf. Computer Communications","author":"Qian S.","year":"2014"},{"issue":"3","key":"S0218194022500619BIB013","doi-asserted-by":"crossref","first-page":"251","DOI":"10.14778\/3291264.3291270","volume":"12","author":"Ji S.","year":"2018","journal-title":"Proc. VLDB Endow."},{"key":"S0218194022500619BIB014","doi-asserted-by":"crossref","first-page":"71","DOI":"10.1145\/1385989.1385999","volume-title":"Proc. Second Int. Conf. Distributed Event-Based Systems","author":"Jerzak Z.","year":"2008"},{"key":"S0218194022500619BIB015","doi-asserted-by":"crossref","first-page":"213","DOI":"10.1016\/j.comnet.2018.12.001","volume":"149","author":"Qian S.","year":"2019","journal-title":"Comput. Netw."},{"key":"S0218194022500619BIB016","first-page":"236","volume-title":"IEEE Int. Conf. Parallel & Distributed Processing with Applications, Big Data & Cloud Computing, Sustainable Computing & Communications, Social Computing & Networking","author":"Ding T.","year":"2020"},{"key":"S0218194022500619BIB017","first-page":"1936","volume-title":"IEEE Conf. Computer Communications","author":"Qian S.","year":"2019"},{"key":"S0218194022500619BIB018","doi-asserted-by":"crossref","first-page":"277","DOI":"10.1007\/978-3-031-00123-9_23","volume-title":"Database Systems for Advanced Applications - 27th Int. Conf., Proc., Part I","author":"Shi W.","year":"2022"},{"key":"S0218194022500619BIB019","doi-asserted-by":"crossref","first-page":"53","DOI":"10.1145\/301308.301326","volume-title":"Proc. Eighteenth Annual ACM Symp. Principles of Distributed Computing","author":"Aguilera M. K.","year":"1999"},{"issue":"2","key":"S0218194022500619BIB020","doi-asserted-by":"crossref","first-page":"1","DOI":"10.1145\/2487259.2487260","volume":"38","author":"Sadoghi M.","year":"2013","journal-title":"ACM Trans. Database Syst."},{"key":"S0218194022500619BIB021","first-page":"163","volume-title":"Proc. ACM SIGCOMM 2003 Conf. Applications, Technologies, Architectures, and Protocols for Computer Communication","author":"Carzaniga A.","year":"2003"},{"key":"S0218194022500619BIB022","first-page":"443","volume-title":"Proc. 23rd Int. Conf. Software Engineering","author":"Campailla A.","year":"2001"},{"key":"S0218194022500619BIB023","first-page":"447","volume-title":"25th Int. Conf. Distributed Computing Systems","author":"Li G.","year":"2005"},{"key":"S0218194022500619BIB024","first-page":"21:1","volume-title":"Proc. 48th Int. Conf. Parallel Processing","author":"Liao Z.","year":"2019"},{"key":"S0218194022500619BIB025","first-page":"1","volume-title":"Proc. Third ACM Int. Conf. Distributed Event-Based Systems","author":"Farroukh A.","year":"2009"},{"key":"S0218194022500619BIB026","first-page":"3:1","volume-title":"Proc. 6th Middleware Doctoral Symp.","author":"Tsakalozos K.","year":"2009"},{"issue":"1","key":"S0218194022500619BIB027","doi-asserted-by":"crossref","first-page":"126","DOI":"10.1109\/TPDS.2013.39","volume":"25","author":"Margara A.","year":"2014","journal-title":"IEEE Trans. Parallel Distrib. Syst."},{"issue":"4","key":"S0218194022500619BIB028","doi-asserted-by":"crossref","first-page":"5839","DOI":"10.1002\/widm.1249","volume":"8","author":"Sagi O.","year":"2018","journal-title":"Wiley Interdiscip. Rev., Data Min. Knowl. Discov."},{"key":"S0218194022500619BIB029","first-page":"1","volume-title":"35th Annual IEEE Int. Conf. Computer Communications","author":"Fan W.","year":"2016"}],"container-title":["International Journal of Software Engineering and Knowledge Engineering"],"original-title":[],"language":"en","link":[{"URL":"https:\/\/www.worldscientific.com\/doi\/pdf\/10.1142\/S0218194022500619","content-type":"unspecified","content-version":"vor","intended-application":"similarity-checking"}],"deposited":{"date-parts":[[2023,2,7]],"date-time":"2023-02-07T02:47:43Z","timestamp":1675738063000},"score":1,"resource":{"primary":{"URL":"https:\/\/www.worldscientific.com\/doi\/10.1142\/S0218194022500619"}},"subtitle":[],"short-title":[],"issued":{"date-parts":[[2022,10,25]]},"references-count":29,"journal-issue":{"issue":"11n12","published-print":{"date-parts":[[2022,11]]}},"alternative-id":["10.1142\/S0218194022500619"],"URL":"https:\/\/doi.org\/10.1142\/s0218194022500619","relation":{},"ISSN":["0218-1940","1793-6403"],"issn-type":[{"value":"0218-1940","type":"print"},{"value":"1793-6403","type":"electronic"}],"subject":[],"published":{"date-parts":[[2022,10,25]]}}}