{"status":"ok","message-type":"work","message-version":"1.0.0","message":{"indexed":{"date-parts":[[2026,6,9]],"date-time":"2026-06-09T15:28:22Z","timestamp":1781018902142,"version":"3.54.1"},"publisher-location":"New York, NY, USA","reference-count":33,"publisher":"ACM","license":[{"start":{"date-parts":[[2026,3,23]],"date-time":"2026-03-23T00:00:00Z","timestamp":1774224000000},"content-version":"vor","delay-in-days":0,"URL":"https:\/\/creativecommons.org\/licenses\/by\/4.0\/legalcode"}],"funder":[{"name":"Indo-French Centre for the Promotion of Advanced Research (CEFIPRA\/IFCPAR)","award":["7102-2"],"award-info":[{"award-number":["7102-2"]}]}],"content-domain":{"domain":["dl.acm.org"],"crossmark-restriction":true},"short-container-title":[],"published-print":{"date-parts":[[2026,3,23]]},"DOI":"10.1145\/3748522.3779839","type":"proceedings-article","created":{"date-parts":[[2026,6,9]],"date-time":"2026-06-09T14:17:49Z","timestamp":1781014669000},"page":"569-576","update-policy":"https:\/\/doi.org\/10.1145\/crossmark-policy","source":"Crossref","is-referenced-by-count":0,"title":["Low-latency Distributed Stream Processing using Asynchronous Progress Tracking"],"prefix":"10.1145","author":[{"ORCID":"https:\/\/orcid.org\/0009-0007-3367-5003","authenticated-orcid":false,"given":"Chinmay","family":"Parekh","sequence":"first","affiliation":[{"name":"IIIT Bangalore, Bangalore, India"}],"role":[{"vocabulary":"crossref","role":"author"}]},{"ORCID":"https:\/\/orcid.org\/0000-0001-7968-262X","authenticated-orcid":false,"given":"Guillaume","family":"Raschia","sequence":"additional","affiliation":[{"name":"LS2N, Polytech Nantes, Nantes, France"}],"role":[{"vocabulary":"crossref","role":"author"}]},{"ORCID":"https:\/\/orcid.org\/0000-0003-4429-9932","authenticated-orcid":false,"given":"Vinu","family":"Ellampallil Venugopal","sequence":"additional","affiliation":[{"name":"IIIT Bangalore, Bangalore, India"}],"role":[{"vocabulary":"crossref","role":"author"}]}],"member":"320","published-online":{"date-parts":[[2026,6,9]]},"reference":[{"key":"e_1_3_2_1_1_1","volume-title":"Proceedings of the Conference on Innovative Data Systems Research (CIDR)","volume":"2005","author":"Abadi Daniel J.","year":"2005","unstructured":"Daniel J. Abadi, Yanif Ahmad, Magdalena Balazinska, Ugur Cetintemel, Mitch Cherniack, Jeong-Hyon Hwang, Wolfgang Lindner, Anurag Maskey, Alex Rasin, Esther Ryvkina, et al. 2005. The design of the Borealis stream processing engine. In Proceedings of the Conference on Innovative Data Systems Research (CIDR), Vol. 2005. 277\u2013289."},{"key":"e_1_3_2_1_2_1","doi-asserted-by":"publisher","DOI":"10.1007\/s00778-003-0095-z"},{"key":"e_1_3_2_1_3_1","doi-asserted-by":"publisher","DOI":"10.14778\/2536222.2536229"},{"key":"e_1_3_2_1_4_1","doi-asserted-by":"publisher","DOI":"10.14778\/2824032.2824076"},{"key":"e_1_3_2_1_5_1","volume-title":"Streaming Systems: The What, Where, When, and How of Large-Scale Data Processing","author":"Akidau Tyler","year":"2018","unstructured":"Tyler Akidau, Slava Chernyak, and Reuven Lax. 2018. Streaming Systems: The What, Where, When, and How of Large-Scale Data Processing. O'Reilly Media, Inc."},{"key":"e_1_3_2_1_6_1","volume-title":"Etalis: Rule-based reasoning in event processing. Reasoning in event-based distributed systems","author":"Anicic Darko","year":"2011","unstructured":"Darko Anicic, Paul Fodor, Sebastian Rudolph, Roland St\u00fchmer, Nenad Stojanovic, and Rudi Studer. 2011. Etalis: Rule-based reasoning in event processing. Reasoning in event-based distributed systems, Springer (2011), 99\u2013124."},{"key":"e_1_3_2_1_7_1","unstructured":"Apache Spark. 2023. Structured Streaming Programming Guide. https:\/\/spark.apache.org\/docs\/latest\/streaming\/. Accessed: 2025-12-10."},{"key":"e_1_3_2_1_8_1","volume-title":"Proceedings of the 23rd International Conference on Extending Database Technology (EDBT)","volume":"20","author":"Benson Lawrence","year":"2020","unstructured":"Lawrence Benson, Philipp M. Grulich, Steffen Zeuch, Volker Markl, and Tilmann Rabl. 2020. Disco: Efficient distributed window aggregation. In Proceedings of the 23rd International Conference on Extending Database Technology (EDBT), Vol. 20. 423\u2013426."},{"key":"e_1_3_2_1_9_1","doi-asserted-by":"publisher","DOI":"10.14778\/3137765.3137777"},{"key":"e_1_3_2_1_10_1","volume-title":"Apache flink: Stream and batch processing in a single engine. The Bulletin of the Technical Committee on Data Engineering 38, 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. The Bulletin of the Technical Committee on Data Engineering 38, 4 (2015)."},{"key":"e_1_3_2_1_11_1","doi-asserted-by":"publisher","DOI":"10.1145\/2983323.2983807"},{"key":"e_1_3_2_1_12_1","doi-asserted-by":"publisher","DOI":"10.14778\/2735496.2735503"},{"key":"e_1_3_2_1_13_1","volume-title":"SASE: Complex event processing over streams. arXiv preprint cs\/0612128","author":"Gyllstrom Daniel","year":"2006","unstructured":"Daniel Gyllstrom, Eugene Wu, Hee-Jin Chae, Yanlei Diao, Patrick Stahlberg, and Gordon Anderson. 2006. SASE: Complex event processing over streams. arXiv preprint cs\/0612128 (2006)."},{"key":"e_1_3_2_1_14_1","doi-asserted-by":"publisher","DOI":"10.14778\/3372716.3372718"},{"key":"e_1_3_2_1_15_1","doi-asserted-by":"publisher","DOI":"10.1145\/1142473.1142543"},{"key":"e_1_3_2_1_16_1","volume-title":"Proceedings of the 2005 ACM SIGMOD International Conference on Management of Data. 311\u2013322","author":"Li Jin","unstructured":"Jin Li, David Maier, Kristin Tufte, Vassilis Papadimos, and Peter A. Tucker. 2005. Semantics and evaluation techniques for window aggregates in data streams. In Proceedings of the 2005 ACM SIGMOD International Conference on Management of Data. 311\u2013322."},{"key":"e_1_3_2_1_17_1","doi-asserted-by":"publisher","DOI":"10.14778\/1453856.1453890"},{"key":"e_1_3_2_1_18_1","volume-title":"Stream Processing with Apache Spark: Mastering Structured Streaming and Spark Streaming","author":"Maas Gerard","unstructured":"Gerard Maas and Francois Garillot. 2019. Stream Processing with Apache Spark: Mastering Structured Streaming and Spark Streaming. O'Reilly Media."},{"key":"e_1_3_2_1_19_1","doi-asserted-by":"publisher","DOI":"10.1145\/2517349.2522738"},{"key":"e_1_3_2_1_20_1","doi-asserted-by":"publisher","DOI":"10.14778\/3137765.3137770"},{"key":"e_1_3_2_1_21_1","volume-title":"Proceedings of the 25th International Conference on Very Large Data Bases (VLDB). 709\u2013720","author":"Raman Vijayshankar","unstructured":"Vijayshankar Raman, Bhaskaran Raman, and Joseph M. Hellerstein. 1999. Online dynamic reordering for interactive data processing. In Proceedings of the 25th International Conference on Very Large Data Bases (VLDB). 709\u2013720."},{"key":"e_1_3_2_1_22_1","doi-asserted-by":"publisher","DOI":"10.1145\/3085504.3085509"},{"key":"e_1_3_2_1_23_1","doi-asserted-by":"publisher","DOI":"10.1145\/1055558.1055596"},{"key":"e_1_3_2_1_24_1","doi-asserted-by":"publisher","DOI":"10.14778\/2752939.2752940"},{"key":"e_1_3_2_1_25_1","doi-asserted-by":"publisher","DOI":"10.1145\/3433675"},{"key":"e_1_3_2_1_26_1","doi-asserted-by":"publisher","DOI":"10.1109\/TKDE.2003.1198390"},{"key":"e_1_3_2_1_27_1","doi-asserted-by":"publisher","DOI":"10.5555\/645927.672188"},{"key":"e_1_3_2_1_28_1","doi-asserted-by":"publisher","DOI":"10.1109\/BigData50022.2020.9377752"},{"key":"e_1_3_2_1_29_1","doi-asserted-by":"publisher","DOI":"10.1109\/SBAC-PAD49847.2020.00018"},{"key":"e_1_3_2_1_30_1","doi-asserted-by":"publisher","DOI":"10.1016\/j.jpdc.2022.04.022"},{"key":"e_1_3_2_1_31_1","doi-asserted-by":"publisher","DOI":"10.1145\/3448016.3457556"},{"key":"e_1_3_2_1_32_1","volume-title":"Hadoop: The Definitive Guide","author":"White Tom","year":"2012","unstructured":"Tom White. 2012. Hadoop: The Definitive Guide. O'Reilly Media."},{"key":"e_1_3_2_1_33_1","doi-asserted-by":"publisher","DOI":"10.1145\/1142473.1142520"}],"event":{"name":"SAC '26: 41st ACM\/SIGAPP Symposium on Applied Computing","location":"Grand Hotel Palace Thessaloniki Greece","acronym":"SAC '26","sponsor":["SIGAPP ACM Special Interest Group on Applied Computing"]},"container-title":["Proceedings of the 41st ACM\/SIGAPP Symposium on Applied Computing"],"original-title":[],"link":[{"URL":"https:\/\/dl.acm.org\/doi\/pdf\/10.1145\/3748522.3779839","content-type":"unspecified","content-version":"vor","intended-application":"similarity-checking"}],"deposited":{"date-parts":[[2026,6,9]],"date-time":"2026-06-09T14:43:19Z","timestamp":1781016199000},"score":1,"resource":{"primary":{"URL":"https:\/\/dl.acm.org\/doi\/10.1145\/3748522.3779839"}},"subtitle":[],"short-title":[],"issued":{"date-parts":[[2026,3,23]]},"references-count":33,"alternative-id":["10.1145\/3748522.3779839","10.1145\/3748522"],"URL":"https:\/\/doi.org\/10.1145\/3748522.3779839","relation":{},"subject":[],"published":{"date-parts":[[2026,3,23]]},"assertion":[{"value":"2026-06-09","order":3,"name":"published","label":"Published","group":{"name":"publication_history","label":"Publication History"}}]}}