{"status":"ok","message-type":"work","message-version":"1.0.0","message":{"indexed":{"date-parts":[[2026,3,14]],"date-time":"2026-03-14T09:53:59Z","timestamp":1773482039091,"version":"3.50.1"},"reference-count":23,"publisher":"Association for Computing Machinery (ACM)","issue":"10","content-domain":{"domain":[],"crossmark-restriction":false},"short-container-title":["Proc. VLDB Endow."],"published-print":{"date-parts":[[2011,7]]},"abstract":"<jats:p>State-of-the-art Complex Event Processing technology (CEP), while effective for pattern query execution, is limited in its capability of reacting to opportunities and risks detected by pattern queries. Especially reactions that affect the query results in turn have not been addressed in the literature. We propose to tackle these unsolved problems by embedding active rule support within the CEP engine, henceforth called Active CEP (ACEP). Active rules in ACEP allow us to specify a pattern query's dynamic condition and real-time actions. The technical challenge is to handle interactions between queries and reactions to queries in the high-volume stream execution. We hence introduce a novel stream-oriented transactional model along with a family of stream transaction scheduling algorithms that ensure the correctness of concurrent stream execution. We demonstrate the power of ACEP technology by applying it to the development of a healthcare system being deployed in UMass Medical School hospital. Through extensive performance experiments using real data streams, we show that our unique Low-Water-Mark stream transaction scheduler, customized for streaming environments, successfully achieves near-real-time system responsiveness and gives orders-of-magnitude better throughput than our alternative schedulers.<\/jats:p>","DOI":"10.14778\/2021017.2021021","type":"journal-article","created":{"date-parts":[[2014,6,24]],"date-time":"2014-06-24T12:17:57Z","timestamp":1403612277000},"page":"634-645","source":"Crossref","is-referenced-by-count":43,"title":["Active complex event processing over event streams"],"prefix":"10.14778","volume":"4","author":[{"given":"Di","family":"Wang","sequence":"first","affiliation":[{"name":"Worcester Polytechnic Institute, Worcester, MA"}],"role":[{"role":"author","vocabulary":"crossref"}]},{"given":"Elke A.","family":"Rundensteiner","sequence":"additional","affiliation":[{"name":"Worcester Polytechnic Institute, Worcester, MA"}],"role":[{"role":"author","vocabulary":"crossref"}]},{"suffix":"III","given":"Richard T.","family":"Ellison","sequence":"additional","affiliation":[{"name":"UMass Medical School, Worcester, MA"}],"role":[{"role":"author","vocabulary":"crossref"}]}],"member":"320","published-online":{"date-parts":[[2011,7]]},"reference":[{"key":"e_1_2_1_1_1","first-page":"1558","volume-title":"VLDB Demo","author":"Ali M. H.","year":"2008"},{"key":"e_1_2_1_2_1","doi-asserted-by":"crossref","unstructured":"P. Bernstein and E. Newcomer. Principles of Transaction Processing. Elsevier second edition 2009.  P. Bernstein and E. Newcomer. Principles of Transaction Processing . Elsevier second edition 2009.","DOI":"10.1016\/B978-1-55860-623-4.00002-0"},{"key":"e_1_2_1_3_1","first-page":"1","article-title":"Guideline for hand hygiene in healthcare settings","volume":"51","author":"Boyce J. M.","year":"2002","journal-title":"MMWR Recomm Rep."},{"key":"e_1_2_1_4_1","unstructured":"Sybase CEP. Coral8 engine. http:\/\/www.sybase.com\/products.  Sybase CEP. Coral8 engine. http:\/\/www.sybase.com\/products."},{"key":"e_1_2_1_5_1","doi-asserted-by":"publisher","DOI":"10.14778\/1687627.1687655"},{"key":"e_1_2_1_6_1","doi-asserted-by":"publisher","DOI":"10.1145\/130283.130296"},{"issue":"1","key":"e_1_2_1_7_1","first-page":"19","article-title":"Stream: the stanford stream data manager","volume":"26","author":"Arasu A.","year":"2003","journal-title":"IEEE Data Eng. Bull."},{"key":"e_1_2_1_8_1","first-page":"412","volume-title":"CIDR","author":"Demers A.","year":"2007"},{"key":"e_1_2_1_9_1","doi-asserted-by":"publisher","DOI":"10.1109\/CEC.2009.74"},{"key":"e_1_2_1_10_1","doi-asserted-by":"publisher","DOI":"10.1145\/44203.44208"},{"key":"e_1_2_1_11_1","doi-asserted-by":"publisher","DOI":"10.14778\/1920841.1921034"},{"key":"e_1_2_1_12_1","doi-asserted-by":"publisher","DOI":"10.1145\/1142473.1142520"},{"key":"e_1_2_1_13_1","volume-title":"CIDR","author":"Cherniack M.","year":"2003"},{"key":"e_1_2_1_14_1","doi-asserted-by":"publisher","DOI":"10.1109\/ICDE.2009.95"},{"key":"e_1_2_1_15_1","doi-asserted-by":"publisher","DOI":"10.1145\/1559845.1559971"},{"key":"e_1_2_1_16_1","first-page":"363","volume-title":"CIDR","author":"Barga R. S.","year":"2007"},{"key":"e_1_2_1_17_1","doi-asserted-by":"publisher","DOI":"10.1145\/1559845.1559867"},{"key":"e_1_2_1_18_1","unstructured":"U. S. Centers for Disease Control and Prevention. http:\/\/www.cdc.gov\/ncidod\/dhqp\/hai.html.  U. S. Centers for Disease Control and Prevention. http:\/\/www.cdc.gov\/ncidod\/dhqp\/hai.html."},{"key":"e_1_2_1_19_1","volume-title":"Morgan Kaufmann","year":"1992"},{"key":"e_1_2_1_20_1","doi-asserted-by":"publisher","DOI":"10.1145\/311531.311623"},{"key":"e_1_2_1_21_1","doi-asserted-by":"publisher","DOI":"10.1145\/1055558.1055596"},{"key":"e_1_2_1_22_1","doi-asserted-by":"publisher","DOI":"10.1007\/s00778-009-0139-0"},{"key":"e_1_2_1_23_1","doi-asserted-by":"crossref","unstructured":"J. Widom. The starburst rule system: Language design implementation and applications. IEEE DE Bull. 15(4) 1992.  J. Widom. The starburst rule system: Language design implementation and applications. IEEE DE Bull . 15(4) 1992.","DOI":"10.1145\/140979.140980"}],"container-title":["Proceedings of the VLDB Endowment"],"original-title":[],"language":"en","link":[{"URL":"https:\/\/dl.acm.org\/doi\/pdf\/10.14778\/2021017.2021021","content-type":"unspecified","content-version":"vor","intended-application":"similarity-checking"}],"deposited":{"date-parts":[[2022,12,28]],"date-time":"2022-12-28T09:42:11Z","timestamp":1672220531000},"score":1,"resource":{"primary":{"URL":"https:\/\/dl.acm.org\/doi\/10.14778\/2021017.2021021"}},"subtitle":[],"short-title":[],"issued":{"date-parts":[[2011,7]]},"references-count":23,"journal-issue":{"issue":"10","published-print":{"date-parts":[[2011,7]]}},"alternative-id":["10.14778\/2021017.2021021"],"URL":"https:\/\/doi.org\/10.14778\/2021017.2021021","relation":{},"ISSN":["2150-8097"],"issn-type":[{"value":"2150-8097","type":"print"}],"subject":[],"published":{"date-parts":[[2011,7]]}}}