{"status":"ok","message-type":"work","message-version":"1.0.0","message":{"indexed":{"date-parts":[[2026,3,31]],"date-time":"2026-03-31T07:42:06Z","timestamp":1774942926732,"version":"3.50.1"},"reference-count":41,"publisher":"Association for Computing Machinery (ACM)","issue":"1","license":[{"start":{"date-parts":[[2023,5,26]],"date-time":"2023-05-26T00:00:00Z","timestamp":1685059200000},"content-version":"vor","delay-in-days":0,"URL":"https:\/\/www.acm.org\/publications\/policies\/copyright_policy#Background"}],"funder":[{"name":"DFG Priority Program","award":["MA4662-5"],"award-info":[{"award-number":["MA4662-5"]}]},{"name":"German Federal Ministry of Education and Research (BMBF) under grants BIFOLD - Berlin Institute for the Foundations of Learning and Data","award":["01IS18037A"],"award-info":[{"award-number":["01IS18037A"]}]},{"name":"German Federal Ministry of Education and Research (BMBF) under grants BBDC - Berlin Big Data Center","award":["01IS18025A"],"award-info":[{"award-number":["01IS18025A"]}]},{"name":"National Research Foundation, Singapore and Infocomm Media Development Authority under its Future Communications Research & Development Programme","award":["CP-SUTD-RG-2022-005"],"award-info":[{"award-number":["CP-SUTD-RG-2022-005"]}]},{"name":"SUTD Start-up Research Grant","award":["SRT3IS21164"],"award-info":[{"award-number":["SRT3IS21164"]}]},{"DOI":"10.13039\/501100001809","name":"National Natural Science Foundation of China","doi-asserted-by":"publisher","award":["62072198"],"award-info":[{"award-number":["62072198"]}],"id":[{"id":"10.13039\/501100001809","id-type":"DOI","asserted-by":"publisher"}]}],"content-domain":{"domain":[],"crossmark-restriction":false},"short-container-title":["Proc. ACM Manag. Data"],"published-print":{"date-parts":[[2023,5,26]]},"abstract":"<jats:p>Transactional stream processing engines (TSPEs) differ significantly in their designs, but all rely on non- adaptive scheduling strategies for processing concurrent state transactions. Subsequently, none exploit multicore parallelism to its full potential due to complex workload dependencies. This paper introduces MorphStream, which adopts a novel approach by decomposing scheduling strategies into three dimensions and then strives to make the right decision along each dimension, based on analyzing the decision trade-offs under varying workload characteristics. Compared to the state-of-the-art, MorphStream achieves up to 3.4 times higher throughput and 69.1% lower processing latency for handling real-world use cases with complex and dynamically changing workload dependencies.<\/jats:p>","DOI":"10.1145\/3588913","type":"journal-article","created":{"date-parts":[[2023,5,30]],"date-time":"2023-05-30T17:42:05Z","timestamp":1685468525000},"page":"1-26","source":"Crossref","is-referenced-by-count":12,"title":["MorphStream: Adaptive Scheduling for Scalable Transactional Stream Processing on Multicores"],"prefix":"10.1145","volume":"1","author":[{"ORCID":"https:\/\/orcid.org\/0000-0002-7824-5978","authenticated-orcid":false,"given":"Yancan","family":"Mao","sequence":"first","affiliation":[{"name":"National University of Singapore, Singapore, Singapore"}]},{"ORCID":"https:\/\/orcid.org\/0009-0002-4008-1821","authenticated-orcid":false,"given":"Jianjun","family":"Zhao","sequence":"additional","affiliation":[{"name":"Huazhong University of Science and Technology, Wuhan, China"}]},{"ORCID":"https:\/\/orcid.org\/0000-0002-9927-6925","authenticated-orcid":false,"given":"Shuhao","family":"Zhang","sequence":"additional","affiliation":[{"name":"Singapore University of Technology and Design, Singapore, Singapore"}]},{"ORCID":"https:\/\/orcid.org\/0000-0003-4290-1408","authenticated-orcid":false,"given":"Haikun","family":"Liu","sequence":"additional","affiliation":[{"name":"Huazhong University of Science and Technology, Wuhan, China"}]},{"ORCID":"https:\/\/orcid.org\/0009-0009-0964-026X","authenticated-orcid":false,"given":"Volker","family":"Markl","sequence":"additional","affiliation":[{"name":"Technische Universit\u00e4t Berlin, Berlin, Germany"}]}],"member":"320","published-online":{"date-parts":[[2023,5,30]]},"reference":[{"key":"e_1_2_2_1_1","unstructured":"2018. Data Artisans Streaming Ledger Serializable ACID Transactions on Streaming Data https:\/\/www.data-artisans.com\/blog\/serializable-acid-transactions-on-streaming-data. (2018)."},{"key":"e_1_2_2_2_1","unstructured":"(2018). Serializable ACID Transactions on Streaming Data. https:\/\/www.ververica.com\/blog\/serializable-acid-transactions-on-streaming-data"},{"key":"e_1_2_2_3_1","doi-asserted-by":"publisher","DOI":"10.1145\/3093742.3093929"},{"key":"e_1_2_2_4_1","doi-asserted-by":"publisher","DOI":"10.1016\/j.jpdc.2020.03.003"},{"key":"e_1_2_2_5_1","doi-asserted-by":"publisher","DOI":"10.1007\/s00778-004-0147-z"},{"key":"e_1_2_2_6_1","volume-title":"Proceedings of the Thirtieth International Conference on Very Large Data Bases -","volume":"30","author":"Arasu Arvind","year":"2004","unstructured":"Arvind Arasu, Mitch Cherniack, Eduardo Galvez, David Maier, Anurag S. Maskey, Esther Ryvkina, Michael Stonebraker, and Richard Tibbetts. 2004. Linear Road: A Stream Data Management Benchmark. In Proceedings of the Thirtieth International Conference on Very Large Data Bases - Volume 30 (Toronto, Canada) (Vldb '04). VLDB Endowment, 480--491. http:\/\/dl.acm.org\/citation.cfm?id=1316689.1316732"},{"key":"e_1_2_2_7_1","first-page":"9","article-title":"Concurrency Control for Step-decomposed","volume":"1999","author":"Bernstein Arthur J.","year":"1999","unstructured":"Arthur J. Bernstein and et al. 1999. Concurrency Control for Step-decomposed Transactions. Inf. Syst. 1999 24, 9 (Dec. 1999), 673--698. http:\/\/dl.acm.org\/citation.cfm?id=337919.337922","journal-title":"Transactions. Inf. Syst."},{"key":"e_1_2_2_8_1","doi-asserted-by":"publisher","DOI":"10.1007\/978--3--642--14559--9"},{"key":"e_1_2_2_9_1","doi-asserted-by":"publisher","DOI":"10.1145\/2247596.2247622"},{"key":"e_1_2_2_10_1","volume-title":"Apache flink: Stream and batch processing in a single engine. Bulletin of the IEEE Computer Society Technical Committee on Data Engineering 36, 4","author":"Carbone Paris","year":"2015","unstructured":"Paris Carbone, Asterios Katsifodimos, Stephan Ewen, Volker Markl, Seif Haridi, and Kostas Tzoumas. 2015. Apache flink: Stream and batch processing in a single engine. Bulletin of the IEEE Computer Society Technical Committee on Data Engineering 36, 4 (2015). http:\/\/flink.apache.org\/"},{"key":"e_1_2_2_11_1","doi-asserted-by":"publisher","DOI":"10.14778\/2733004.2733048"},{"key":"e_1_2_2_12_1","first-page":"28","article-title":"Cisc 499*","volume":"6","author":"Conway Neil","year":"2008","unstructured":"Neil Conway. 2008. Cisc 499*: Transactions and data stream processing. Apr 6 (2008), 28.","journal-title":"Apr"},{"key":"e_1_2_2_13_1","doi-asserted-by":"publisher","DOI":"10.14778\/3484224.3484234"},{"key":"e_1_2_2_14_1","doi-asserted-by":"publisher","DOI":"10.1145\/167088.167254"},{"key":"e_1_2_2_16_1","volume-title":"STREAM: The Stanford stream data manager. Technical Report. Stanford InfoLab.","author":"STREAM Group et al.","year":"2003","unstructured":"STREAM Group et al. 2003. STREAM: The Stanford stream data manager. Technical Report. Stanford InfoLab."},{"key":"e_1_2_2_17_1","volume-title":"Scheduling to minimize average completion time: Off-line and on-line approximation algorithms. Mathematics of operations research 22, 3","author":"Hall Leslie A","year":"1997","unstructured":"Leslie A Hall, Andreas S Schulz, David B Shmoys, and Joel Wein. 1997. Scheduling to minimize average completion time: Off-line and on-line approximation algorithms. Mathematics of operations research 22, 3 (1997), 513--544."},{"key":"e_1_2_2_18_1","doi-asserted-by":"publisher","DOI":"10.1109\/71.265940"},{"key":"e_1_2_2_19_1","doi-asserted-by":"publisher","DOI":"10.1109\/IPPS.1998.669967"},{"key":"e_1_2_2_20_1","doi-asserted-by":"publisher","DOI":"10.1145\/344588.344618"},{"key":"e_1_2_2_21_1","unstructured":"John Meehan Cansu Aslantas Stan Zdonik Nesime Tatbul and Jiang Du. 2017. Data Ingestion for the Connected World.. In CIDR."},{"key":"e_1_2_2_22_1","doi-asserted-by":"publisher","DOI":"10.14778\/2831360.2831367"},{"key":"e_1_2_2_23_1","doi-asserted-by":"publisher","DOI":"10.5555\/1141023.1705236"},{"key":"e_1_2_2_24_1","doi-asserted-by":"publisher","DOI":"10.1007\/978-0--387-09766--4_42"},{"key":"e_1_2_2_25_1","volume-title":"Web Engineering","author":"Sahin Ozlem Ceren","unstructured":"Ozlem Ceren Sahin, Pinar Karagoz, and Nesime Tatbul. 2019. Streaming Event Detection in Microblogs: Balancing Accuracy and Performance. In Web Engineering, Maxim Bakaev, Flavius Frasincar, and In Young Ko (Eds.). Springer International Publishing, Cham, 123--138."},{"key":"e_1_2_2_26_1","doi-asserted-by":"publisher","DOI":"10.1145\/211414.211427"},{"key":"e_1_2_2_27_1","doi-asserted-by":"publisher","DOI":"10.1145\/3299869.3300067"},{"key":"e_1_2_2_28_1","doi-asserted-by":"publisher","DOI":"10.1145\/1107499.1107504"},{"key":"e_1_2_2_29_1","volume-title":"Proc VLDB Endow.","author":"Stonebraker Michael","year":"2007","unstructured":"Michael Stonebraker, Samuel Madden, Daniel J. Abadi, Stavros Harizopoulos, Nabil Hachem, and Pat Helland. [n. d.]. The End of an Architectural Era: (It's Time for a Complete Rewrite). In Proc VLDB Endow. 2007."},{"key":"e_1_2_2_30_1","doi-asserted-by":"publisher","unstructured":"Jun Tan and Ming Zhong. 2014-05. An Online Bidding System (OBS) under Price Match Mechanism for Commercial Procurement. Applied Mechanics and Materials 556--562 (2014-05) 6540--6543. https:\/\/doi.org\/10.4028\/www.scientific.net\/AMM.556--562.6540","DOI":"10.4028\/www.scientific.net"},{"key":"e_1_2_2_31_1","doi-asserted-by":"publisher","DOI":"10.1145\/2588555.2595641"},{"key":"e_1_2_2_32_1","doi-asserted-by":"publisher","DOI":"10.1109\/TKDE.2003.1198390"},{"key":"e_1_2_2_33_1","doi-asserted-by":"publisher","DOI":"10.1109\/tkde.2003.1198390"},{"key":"e_1_2_2_34_1","doi-asserted-by":"publisher","DOI":"10.14778\/2021017.2021021"},{"key":"e_1_2_2_35_1","volume-title":"Transactional information systems: theory, algorithms, and the practice of concurrency control and recovery","author":"Weikum Gerhard","unstructured":"Gerhard Weikum and Gottfried Vossen. 2001. Transactional information systems: theory, algorithms, and the practice of concurrency control and recovery. Elsevier."},{"key":"e_1_2_2_36_1","doi-asserted-by":"publisher","DOI":"10.1145\/3035918.3064011"},{"key":"e_1_2_2_37_1","doi-asserted-by":"publisher","DOI":"10.1109\/ICDCS.2014.61"},{"key":"e_1_2_2_38_1","doi-asserted-by":"publisher","DOI":"10.1109\/TKDE.2016.2578319"},{"key":"e_1_2_2_39_1","doi-asserted-by":"publisher","DOI":"10.1145\/2517349.2522737"},{"key":"e_1_2_2_40_1","volume-title":"Parallelizing Stream Compression for IoT Applications on Asymmetric Multicores. In 2023 IEEE 39th International Conference on Data Engineering (ICDE). IEEE.","author":"Zeng Xianzhi","year":"2023","unstructured":"Xianzhi Zeng and Shuhao Zhang. 2023. Parallelizing Stream Compression for IoT Applications on Asymmetric Multicores. In 2023 IEEE 39th International Conference on Data Engineering (ICDE). IEEE."},{"key":"e_1_2_2_41_1","doi-asserted-by":"publisher","DOI":"10.1109\/ICDE48307.2020.00136"},{"key":"e_1_2_2_42_1","doi-asserted-by":"publisher","DOI":"10.1109\/ICDE55515.2023.00038"}],"container-title":["Proceedings of the ACM on Management of Data"],"original-title":[],"language":"en","link":[{"URL":"https:\/\/dl.acm.org\/doi\/10.1145\/3588913","content-type":"unspecified","content-version":"vor","intended-application":"text-mining"},{"URL":"https:\/\/dl.acm.org\/doi\/pdf\/10.1145\/3588913","content-type":"unspecified","content-version":"vor","intended-application":"similarity-checking"}],"deposited":{"date-parts":[[2025,6,17]],"date-time":"2025-06-17T16:47:36Z","timestamp":1750178856000},"score":1,"resource":{"primary":{"URL":"https:\/\/dl.acm.org\/doi\/10.1145\/3588913"}},"subtitle":[],"short-title":[],"issued":{"date-parts":[[2023,5,26]]},"references-count":41,"journal-issue":{"issue":"1","published-print":{"date-parts":[[2023,5,26]]}},"alternative-id":["10.1145\/3588913"],"URL":"https:\/\/doi.org\/10.1145\/3588913","relation":{},"ISSN":["2836-6573"],"issn-type":[{"value":"2836-6573","type":"electronic"}],"subject":[],"published":{"date-parts":[[2023,5,26]]}}}