{"status":"ok","message-type":"work","message-version":"1.0.0","message":{"indexed":{"date-parts":[[2025,8,23]],"date-time":"2025-08-23T02:10:02Z","timestamp":1755915002987,"version":"3.44.0"},"publisher-location":"New York, NY, USA","reference-count":39,"publisher":"ACM","license":[{"start":{"date-parts":[[2024,6,24]],"date-time":"2024-06-24T00:00:00Z","timestamp":1719187200000},"content-version":"vor","delay-in-days":0,"URL":"https:\/\/creativecommons.org\/licenses\/by\/4.0\/"}],"funder":[{"DOI":"10.13039\/501100006374","name":"Vinnova","doi-asserted-by":"publisher","award":["2022-03036"],"award-info":[{"award-number":["2022-03036"]}],"id":[{"id":"10.13039\/501100006374","id-type":"DOI","asserted-by":"publisher"}]},{"DOI":"10.13039\/501100006374","name":"Swedish e-Science Research Centre","doi-asserted-by":"publisher","id":[{"id":"10.13039\/501100006374","id-type":"DOI","asserted-by":"publisher"}]},{"name":"Swedish Foundation for Strategic Research","award":["BD15-0006"],"award-info":[{"award-number":["BD15-0006"]}]},{"name":"Wallenberg AI NEST"}],"content-domain":{"domain":["dl.acm.org"],"crossmark-restriction":true},"short-container-title":[],"published-print":{"date-parts":[[2024,6,24]]},"DOI":"10.1145\/3629104.3666030","type":"proceedings-article","created":{"date-parts":[[2024,7,22]],"date-time":"2024-07-22T12:15:03Z","timestamp":1721650503000},"page":"42-53","update-policy":"https:\/\/doi.org\/10.1145\/crossmark-policy","source":"Crossref","is-referenced-by-count":0,"title":["AquaLang: A Dataflow Programming Language"],"prefix":"10.1145","author":[{"ORCID":"https:\/\/orcid.org\/0000-0001-7096-4401","authenticated-orcid":false,"given":"Klas","family":"Segeljakt","sequence":"first","affiliation":[{"name":"KTH Royal Institute of Technology, Stockholm, Sweden"}],"role":[{"role":"author","vocabulary":"crossref"}]},{"ORCID":"https:\/\/orcid.org\/0000-0002-6718-0144","authenticated-orcid":false,"given":"Seif","family":"Haridi","sequence":"additional","affiliation":[{"name":"KTH Royal Institute of Technology, RISE Research Institutes of Sweden, Stockholm, Sweden"}],"role":[{"role":"author","vocabulary":"crossref"}]},{"ORCID":"https:\/\/orcid.org\/0000-0002-9351-8508","authenticated-orcid":false,"given":"Paris","family":"Carbone","sequence":"additional","affiliation":[{"name":"KTH Royal Institute of Technology, RISE Research Institutes of Sweden, Stockholm, Sweden"}],"role":[{"role":"author","vocabulary":"crossref"}]}],"member":"320","published-online":{"date-parts":[[2024,7,22]]},"reference":[{"key":"e_1_3_2_1_1_1","doi-asserted-by":"publisher","DOI":"10.5555\/1177220"},{"key":"e_1_3_2_1_2_1","doi-asserted-by":"publisher","DOI":"10.14778\/2824032.2824076"},{"key":"e_1_3_2_1_3_1","volume-title":"Retrieved","author":"Alliance Bytecode","year":"2023","unstructured":"Bytecode Alliance. 2023. Component model. Retrieved May 23, 2024 from https:\/\/component-model.bytecodealliance.org\/"},{"key":"e_1_3_2_1_4_1","doi-asserted-by":"publisher","DOI":"10.1007\/s00778-004-0147-z"},{"key":"e_1_3_2_1_5_1","doi-asserted-by":"publisher","DOI":"10.1145\/3183713.3190664"},{"key":"e_1_3_2_1_6_1","doi-asserted-by":"publisher","DOI":"10.1145\/3183713.3190662"},{"key":"e_1_3_2_1_7_1","doi-asserted-by":"publisher","DOI":"10.14778\/3137765.3137777"},{"key":"e_1_3_2_1_8_1","volume-title":"Apache Flink: Stream and batch processing in a single engine","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. IEEE TCDE 38, 4 (2015). http:\/\/urn.kb.se\/resolve?urn=urn:nbn:se:kth:diva-198940"},{"key":"e_1_3_2_1_9_1","doi-asserted-by":"publisher","unstructured":"Paris Carbone Asterios Katsifodimos and Seif Haridi. 2018. Stream Window Aggregation Semantics and Optimization. (2018). https:\/\/doi.org\/10.1007\/978-3-319-63962-8_154-1","DOI":"10.1007\/978-3-319-63962-8_154-1"},{"key":"e_1_3_2_1_10_1","doi-asserted-by":"publisher","DOI":"10.1145\/2983323.2983807"},{"volume-title":"Retrieved","year":"2024","key":"e_1_3_2_1_11_1","unstructured":"Confluent. 2024. Kafka Streams Overview. Retrieved May 23, 2024 from https:\/\/docs.confluent.io\/platform\/current\/streams\/"},{"key":"e_1_3_2_1_12_1","volume-title":"Retrieved","author":"Developers PRQL","year":"2024","unstructured":"PRQL Developers. 2024. PRQL (Pipelined Relational Query Language). Retrieved May 23, 2024 from https:\/\/prql-lang.org\/"},{"key":"e_1_3_2_1_13_1","doi-asserted-by":"publisher","DOI":"10.5555\/1855741.1855742"},{"key":"e_1_3_2_1_14_1","volume-title":"Retrieved","author":"Foundation Apache Software","year":"2024","unstructured":"Apache Software Foundation. 2024. Apache Beam. Retrieved May 23, 2024 from https:\/\/beam.apache.org\/"},{"key":"e_1_3_2_1_15_1","volume-title":"Retrieved","author":"Foundation Apache Software","year":"2024","unstructured":"Apache Software Foundation. 2024. Flink Table API. Retrieved May 23, 2024 from https:\/\/nightlies.apache.org\/flink\/flink-docs-release-1.18\/docs\/dev\/table\/tableapi\/"},{"key":"e_1_3_2_1_16_1","doi-asserted-by":"publisher","DOI":"10.1007\/s00778-023-00819-8"},{"key":"e_1_3_2_1_17_1","doi-asserted-by":"publisher","DOI":"10.1016\/j.ijinfomgt.2014.10.007"},{"key":"e_1_3_2_1_18_1","doi-asserted-by":"publisher","DOI":"10.1515\/9783110664065"},{"key":"e_1_3_2_1_19_1","doi-asserted-by":"publisher","DOI":"10.1145\/319838.319848"},{"key":"e_1_3_2_1_20_1","volume-title":"Retrieved","author":"W3C WebAssembly Community Group","year":"2024","unstructured":"W3C WebAssembly Community Group. 2024. WASI: The WebAssembly system interface. Retrieved May 23, 2024 from https:\/\/wasi.dev\/"},{"key":"e_1_3_2_1_21_1","doi-asserted-by":"publisher","unstructured":"Andreas Haas and et.al. 2017. Bringing the web up to speed with WebAssembly. In PLDI. ACM. https:\/\/doi.org\/10.1145\/3062341.3062363","DOI":"10.1145\/3062341.3062363"},{"key":"e_1_3_2_1_22_1","doi-asserted-by":"publisher","DOI":"10.1109\/ICDCS.2019.00138"},{"key":"e_1_3_2_1_23_1","doi-asserted-by":"publisher","unstructured":"Martin Hirzel Scott Schneider and Kanat Tangwongsan. 2017. Sliding-Window Aggregation Algorithms: Tutorial. In DEBS. ACM. https:\/\/doi.org\/10.1145\/3093742.3095107","DOI":"10.1145\/3093742.3095107"},{"key":"e_1_3_2_1_24_1","volume-title":"Retrieved","author":"Hyde Julian","year":"2024","unstructured":"Julian Hyde. 2024. Morel: Standard ML with Relational Extensions. Retrieved May 23, 2024 from https:\/\/github.com\/hydromatic\/morel"},{"key":"e_1_3_2_1_25_1","volume-title":"Retrieved","author":"Klas Segeljakt Paris Carbone","year":"2024","unstructured":"Paris Carbone Klas Segeljakt, Seif Haridi. 2024. AquaLang: A Dataflow Programming Language - Appendix. Retrieved May 23, 2024 from https:\/\/aqua-language.github.io\/AquaLang-DEBS2024-Appendix.pdf"},{"key":"e_1_3_2_1_26_1","doi-asserted-by":"publisher","DOI":"10.1007\/978-1-4842-1004-8"},{"key":"e_1_3_2_1_27_1","doi-asserted-by":"publisher","DOI":"10.14778\/3342263.3342633"},{"key":"e_1_3_2_1_28_1","doi-asserted-by":"publisher","DOI":"10.1145\/3563336"},{"key":"e_1_3_2_1_29_1","doi-asserted-by":"publisher","DOI":"10.4204\/EPTCS.153.8"},{"key":"e_1_3_2_1_30_1","doi-asserted-by":"publisher","unstructured":"Sam Lindley and James Cheney. 2012. Row-based effect types for database integration. In TLDI. ACM. https:\/\/doi.org\/10.1145\/2103786.2103798","DOI":"10.1145\/2103786.2103798"},{"volume-title":"Real-Time Insights. Retrieved","year":"2024","key":"e_1_3_2_1_31_1","unstructured":"RisingWave. 2024. RisingWave: Live Data, Real-Time Insights. Retrieved May 23, 2024 from https:\/\/risingwave.com\/"},{"key":"e_1_3_2_1_32_1","doi-asserted-by":"publisher","DOI":"10.1007\/978-3-031-51060-1"},{"key":"e_1_3_2_1_33_1","doi-asserted-by":"publisher","DOI":"10.14778\/3339490.3339499"},{"key":"e_1_3_2_1_34_1","doi-asserted-by":"publisher","DOI":"10.1007\/s00778-021-00668-3"},{"key":"e_1_3_2_1_35_1","doi-asserted-by":"publisher","DOI":"10.5441\/002\/edbt.2019.10"},{"key":"e_1_3_2_1_36_1","unstructured":"Pete Tucker Kristin Tufte Vassilis Papadimos and David Maier. 2008. NEXMark - A Benchmark for Queries over Data Streams. (2008)."},{"key":"e_1_3_2_1_37_1","doi-asserted-by":"publisher","DOI":"10.1145\/3434304"},{"key":"e_1_3_2_1_38_1","doi-asserted-by":"publisher","DOI":"10.5555\/1863103.1863113"},{"key":"e_1_3_2_1_39_1","doi-asserted-by":"publisher","DOI":"10.1007\/s13222-022-00415-0"}],"event":{"name":"DEBS '24: The 18th ACM International Conference on Distributed and Event-based Systems","sponsor":["SIGMOD ACM Special Interest Group on Management of Data","SIGSOFT ACM Special Interest Group on Software Engineering"],"location":"Villeurbanne France","acronym":"DEBS '24"},"container-title":["Proceedings of the 18th ACM International Conference on Distributed and Event-based Systems"],"original-title":[],"link":[{"URL":"https:\/\/dl.acm.org\/doi\/10.1145\/3629104.3666030","content-type":"unspecified","content-version":"vor","intended-application":"text-mining"},{"URL":"https:\/\/dl.acm.org\/doi\/pdf\/10.1145\/3629104.3666030","content-type":"unspecified","content-version":"vor","intended-application":"similarity-checking"}],"deposited":{"date-parts":[[2025,8,23]],"date-time":"2025-08-23T01:44:30Z","timestamp":1755913470000},"score":1,"resource":{"primary":{"URL":"https:\/\/dl.acm.org\/doi\/10.1145\/3629104.3666030"}},"subtitle":[],"short-title":[],"issued":{"date-parts":[[2024,6,24]]},"references-count":39,"alternative-id":["10.1145\/3629104.3666030","10.1145\/3629104"],"URL":"https:\/\/doi.org\/10.1145\/3629104.3666030","relation":{},"subject":[],"published":{"date-parts":[[2024,6,24]]},"assertion":[{"value":"2024-07-22","order":3,"name":"published","label":"Published","group":{"name":"publication_history","label":"Publication History"}}]}}