{"status":"ok","message-type":"work","message-version":"1.0.0","message":{"indexed":{"date-parts":[[2024,10,30]],"date-time":"2024-10-30T22:33:26Z","timestamp":1730327606428,"version":"3.28.0"},"publisher-location":"New York, NY, USA","reference-count":30,"publisher":"ACM","funder":[{"name":"National Recovery and Resilience Plan (NRRP), Mission 4 Component 2 Investment 1.3 - Call for tender No. 1561 of 11.10.2022 of Ministero dell\u00f0Uni- versit\u00e0 e della Ricerca (MUR); funded by the European Union \u00f0 NextGenerationEU","award":["Project code PE0000021, Concession Decree No. 1561 of 11.10.2022 adopted by Ministero dell'Universit\u00e0 e della Ricerca (MUR), CUP - to be indicated by each Benefi- ciary, according to attachment E of Decree No. 1561\/2022"]}],"content-domain":{"domain":["dl.acm.org"],"crossmark-restriction":true},"short-container-title":[],"published-print":{"date-parts":[[2024,6,24]]},"DOI":"10.1145\/3629104.3666029","type":"proceedings-article","created":{"date-parts":[[2024,7,22]],"date-time":"2024-07-22T16:15:03Z","timestamp":1721664903000},"page":"30-41","update-policy":"http:\/\/dx.doi.org\/10.1145\/crossmark-policy","source":"Crossref","is-referenced-by-count":0,"title":["Safe Shared State in Dataflow Systems"],"prefix":"10.1145","author":[{"ORCID":"http:\/\/orcid.org\/0009-0002-5871-8261","authenticated-orcid":false,"given":"Luca","family":"De Martini","sequence":"first","affiliation":[{"name":"Politecnico di Milano, Italy"}]},{"ORCID":"http:\/\/orcid.org\/0000-0002-0023-8639","authenticated-orcid":false,"given":"Alessandro","family":"Margara","sequence":"additional","affiliation":[{"name":"Politecnico di Milano, Italy"}]}],"member":"320","published-online":{"date-parts":[[2024,7,22]]},"reference":[{"key":"e_1_3_2_1_1_1","volume-title":"TensorFlow: A System for Large-Scale Machine Learning. In Symp on Operating Systems Design and Implementation (OSDI '16)","author":"Abadi Mart\u00edn","year":"2016","unstructured":"Mart\u00edn Abadi, Paul Barham, Jianmin Chen, Zhifeng Chen, Andy Davis, Jeffrey Dean, Matthieu Devin, Sanjay Ghemawat, Geoffrey Irving, Michael Isard, Manjunath Kudlur, Josh Levenberg, Rajat Monga, Sherry Moore, Derek G. Murray, Benoit Steiner, Paul Tucker, Vijay Vasudevan, Pete Warden, Martin Wicke, Yuan Yu, and Xiaoqiang Zheng. 2016. TensorFlow: A System for Large-Scale Machine Learning. In Symp on Operating Systems Design and Implementation (OSDI '16). USENIX, 265--283."},{"key":"e_1_3_2_1_2_1","doi-asserted-by":"publisher","DOI":"10.1145\/3093742.3093929"},{"key":"e_1_3_2_1_3_1","doi-asserted-by":"publisher","DOI":"10.1016\/j.jpdc.2020.03.003"},{"volume-title":"Actors: a conceptual foundation for concurrent object-oriented programming","author":"Agha Gul","key":"e_1_3_2_1_4_1","unstructured":"Gul Agha and Carl Hewitt. 1987. Actors: a conceptual foundation for concurrent object-oriented programming. MIT Press, 49--74."},{"key":"e_1_3_2_1_5_1","doi-asserted-by":"publisher","DOI":"10.14778\/2824032.2824076"},{"key":"e_1_3_2_1_6_1","doi-asserted-by":"publisher","DOI":"10.14778\/3137765.3137777"},{"key":"e_1_3_2_1_7_1","unstructured":"Paris Carbone Gyula F\u00f3ra Stephan Ewen Seif Haridi and Kostas Tzoumas. 2015. Lightweight Asynchronous Snapshots for Distributed Dataflows."},{"key":"e_1_3_2_1_8_1","first-page":"28","article-title":"Apache Flink\u2122: Stream and Batch Processing in a Single Engine","volume":"38","author":"Carbone Paris","year":"2015","unstructured":"Paris Carbone, Asterios Katsifodimos, Stephan Ewen, Volker Markl, Seif Haridi, and Kostas Tzoumas. 2015. Apache Flink\u2122: Stream and Batch Processing in a Single Engine. IEEE Data Engineering Bulletin 38, 4 (2015), 28--38.","journal-title":"IEEE Data Engineering Bulletin"},{"key":"e_1_3_2_1_9_1","volume-title":"Matteo Nardelli, and Gabriele Russo Russo.","author":"Cardellini Valeria","year":"2022","unstructured":"Valeria Cardellini, Francesco Lo Presti, Matteo Nardelli, and Gabriele Russo Russo. 2022. Runtime Adaptation of Data Stream Processing Systems: The State of the Art. ACM Comput. Surv. 54, 11s, Article 237 (2022)."},{"key":"e_1_3_2_1_10_1","volume-title":"Int Conf on Management of Data (SIGMOD '13)","author":"Fernandez Raul Castro","year":"2013","unstructured":"Raul Castro Fernandez, Matteo Migliavacca, Evangelia Kalyvianaki, and Peter Pietzuch. 2013. Integrating scale out and fault tolerance in stream processing using operator state management. In Int Conf on Management of Data (SIGMOD '13). ACM, 725--736."},{"key":"e_1_3_2_1_11_1","doi-asserted-by":"publisher","DOI":"10.14778\/2733004.2733048"},{"key":"e_1_3_2_1_12_1","doi-asserted-by":"publisher","DOI":"10.1145\/3465480.3466920"},{"key":"e_1_3_2_1_13_1","doi-asserted-by":"publisher","DOI":"10.1145\/3524860.3539646"},{"key":"e_1_3_2_1_14_1","doi-asserted-by":"publisher","DOI":"10.1145\/1327452.1327492"},{"key":"e_1_3_2_1_15_1","volume-title":"Rethinking Stateful Stream Processing with RDMA. In Int Conf on Management of Data (SIGMOD '22)","author":"Monte Bonaventura Del","year":"2022","unstructured":"Bonaventura Del Monte, Steffen Zeuch, Tilmann Rabl, and Volker Markl. 2022. Rethinking Stateful Stream Processing with RDMA. In Int Conf on Management of Data (SIGMOD '22). ACM, 1078--1092."},{"key":"e_1_3_2_1_16_1","volume-title":"Making State Explicit for Imperative Big Data Processing. In Annual Technical Conf. (ATC'14)","author":"Fernandez Raul Castro","year":"2014","unstructured":"Raul Castro Fernandez, Matteo Migliavacca, Evangelia Kalyvianaki, and Peter Pietzuch. 2014. Making State Explicit for Imperative Big Data Processing. In Annual Technical Conf. (ATC'14). USENIX, 49--60."},{"key":"e_1_3_2_1_17_1","unstructured":"Marios Fragkoulis Paris Carbone VasilikiKalavri and Asterios Katsifodimos. 2023. A survey on the evolution of streamprocessing systems. VLDB Journal(2023) 1--35."},{"key":"e_1_3_2_1_18_1","doi-asserted-by":"publisher","DOI":"10.1145\/3524860.3539645"},{"key":"e_1_3_2_1_19_1","doi-asserted-by":"publisher","DOI":"10.1145\/359576.359585"},{"key":"e_1_3_2_1_20_1","doi-asserted-by":"publisher","DOI":"10.1145\/3418295"},{"key":"e_1_3_2_1_21_1","doi-asserted-by":"publisher","DOI":"10.1145\/3524860.3539649"},{"key":"e_1_3_2_1_22_1","doi-asserted-by":"publisher","DOI":"10.1145\/2723372.2742788"},{"key":"e_1_3_2_1_23_1","volume-title":"Article 16","author":"Margara Alessandro","year":"2023","unstructured":"Alessandro Margara, Gianpaolo Cugola, Nicol\u00f2 Felicioni, and Stefano Cilloni. 2023. A Model and Survey of Distributed Data-Intensive Systems. ACM Comput. Surv. 56, 1, Article 16 (2023)."},{"key":"e_1_3_2_1_24_1","doi-asserted-by":"crossref","unstructured":"Luca De Martini Alessandro Margara Gianpaolo Cugola Marco Donadoni and Edoardo Morassutto. 2023. The Noir Dataflow Platform: Efficient Data Processing without Complexity. arXiv:2306.04421 [cs.DC]","DOI":"10.1016\/j.future.2024.06.018"},{"key":"e_1_3_2_1_25_1","doi-asserted-by":"publisher","DOI":"10.1145\/3519939.3523704"},{"key":"e_1_3_2_1_26_1","volume-title":"Article 36","author":"R\u00f6ger Henriette","year":"2019","unstructured":"Henriette R\u00f6ger and Ruben Mayer. 2019. A Comprehensive Survey on Parallelization and Elasticity in Stream Processing. ACM Comput. Surv. 52, 2, Article 36 (2019)."},{"key":"e_1_3_2_1_27_1","volume-title":"Evaluation of HPC-Big Data Applications Using Cloud Platforms. In Int Symp on Cluster, Cloud and Grid Computing (CCGrid '17)","author":"Salaria Shweta","year":"2017","unstructured":"Shweta Salaria, Kevin Brown, Hideyuki Jitsumoto, and Satoshi Matsuoka. 2017. Evaluation of HPC-Big Data Applications Using Cloud Platforms. In Int Symp on Cluster, Cloud and Grid Computing (CCGrid '17). IEEE, 1053--1061."},{"key":"e_1_3_2_1_28_1","doi-asserted-by":"publisher","DOI":"10.14778\/3489496.3489515"},{"key":"e_1_3_2_1_29_1","doi-asserted-by":"publisher","DOI":"10.1007\/s00778-018-0514-9"},{"key":"e_1_3_2_1_30_1","doi-asserted-by":"publisher","DOI":"10.1145\/2934664"}],"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\/pdf\/10.1145\/3629104.3666029","content-type":"unspecified","content-version":"vor","intended-application":"similarity-checking"}],"deposited":{"date-parts":[[2024,8,22]],"date-time":"2024-08-22T10:29:35Z","timestamp":1724322575000},"score":1,"resource":{"primary":{"URL":"https:\/\/dl.acm.org\/doi\/10.1145\/3629104.3666029"}},"subtitle":[],"short-title":[],"issued":{"date-parts":[[2024,6,24]]},"references-count":30,"alternative-id":["10.1145\/3629104.3666029","10.1145\/3629104"],"URL":"https:\/\/doi.org\/10.1145\/3629104.3666029","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"}}]}}