{"status":"ok","message-type":"work","message-version":"1.0.0","message":{"indexed":{"date-parts":[[2026,6,23]],"date-time":"2026-06-23T06:47:19Z","timestamp":1782197239731,"version":"3.54.5"},"publisher-location":"New York, NY, USA","reference-count":48,"publisher":"ACM","license":[{"start":{"date-parts":[[2024,12,2]],"date-time":"2024-12-02T00:00:00Z","timestamp":1733097600000},"content-version":"vor","delay-in-days":0,"URL":"https:\/\/creativecommons.org\/licenses\/by\/4.0\/"}],"funder":[{"DOI":"10.13039\/100018694","name":"HORIZON EUROPE Marie Sklodowska-Curie Actions","doi-asserted-by":"publisher","award":["01072456"],"award-info":[{"award-number":["01072456"]}],"id":[{"id":"10.13039\/100018694","id-type":"DOI","asserted-by":"publisher"}]},{"DOI":"10.13039\/501100002835","name":"Chalmers tekniska h\u00f6gskola","doi-asserted-by":"publisher","id":[{"id":"10.13039\/501100002835","id-type":"DOI","asserted-by":"publisher"}]}],"content-domain":{"domain":["dl.acm.org"],"crossmark-restriction":true},"short-container-title":[],"published-print":{"date-parts":[[2024,12,2]]},"DOI":"10.1145\/3652892.3654790","type":"proceedings-article","created":{"date-parts":[[2024,11,27]],"date-time":"2024-11-27T19:36:13Z","timestamp":1732736173000},"page":"8-21","update-policy":"https:\/\/doi.org\/10.1145\/crossmark-policy","source":"Crossref","is-referenced-by-count":2,"title":["On the Semantic Overlap of Operators in Stream Processing Engines"],"prefix":"10.1145","author":[{"ORCID":"https:\/\/orcid.org\/0000-0002-2136-9179","authenticated-orcid":false,"given":"Vincenzo","family":"Gulisano","sequence":"first","affiliation":[{"name":"Chalmers University of Technology, Gothenburg, Sweden"}],"role":[{"vocabulary":"crossref","role":"author"}]},{"ORCID":"https:\/\/orcid.org\/0000-0001-9094-8871","authenticated-orcid":false,"given":"Marina","family":"Papatriantafilou","sequence":"additional","affiliation":[{"name":"Chalmers University of Technology, Gothenburg, Sweden"}],"role":[{"vocabulary":"crossref","role":"author"}]},{"ORCID":"https:\/\/orcid.org\/0000-0002-0023-8639","authenticated-orcid":false,"given":"Alessandro","family":"Margara","sequence":"additional","affiliation":[{"name":"Politecnico di Milano, Italy, Milan, Italy"}],"role":[{"vocabulary":"crossref","role":"author"}]}],"member":"320","published-online":{"date-parts":[[2024,12,2]]},"reference":[{"key":"e_1_3_2_1_1_1","doi-asserted-by":"publisher","DOI":"10.14778\/2824032.2824076"},{"key":"e_1_3_2_1_2_1","unstructured":"\"Apache Beam \" https:\/\/beam.apache.org\/ accessed:2024-03-14."},{"key":"e_1_3_2_1_3_1","unstructured":"\"Apache Flink \" https:\/\/flink.apache.org accessed:2024-03-14."},{"key":"e_1_3_2_1_4_1","unstructured":"\"Apache Spark \" https:\/\/spark.apache.org accessed:2024-03-14."},{"key":"e_1_3_2_1_5_1","doi-asserted-by":"publisher","DOI":"10.1109\/TPDS.2012.24"},{"key":"e_1_3_2_1_6_1","doi-asserted-by":"publisher","DOI":"10.1109\/TPDS.2022.3181979"},{"key":"e_1_3_2_1_7_1","unstructured":"\"On the Semantic Overlap of Operators in Stream Processing Engines - code repository \" https:\/\/github.com\/vincenzo-gulisano\/semantic_overlap accessed:2024-03-14."},{"key":"e_1_3_2_1_8_1","unstructured":"\"\u03bcSPE \" https:\/\/github.com\/vincenzo-gulisano\/muSPE accessed:2024-03-14."},{"key":"e_1_3_2_1_9_1","doi-asserted-by":"publisher","DOI":"10.1145\/2463676.2465272"},{"key":"e_1_3_2_1_10_1","doi-asserted-by":"publisher","DOI":"10.1145\/3131272"},{"key":"e_1_3_2_1_11_1","volume-title":"CellJoin: a parallel stream join operator for the cell processor,\" The VLDB journal","author":"Gedik B.","year":"2009","unstructured":"B. Gedik, R. R. Bordawekar, and S. Y. Philip, \"CellJoin: a parallel stream join operator for the cell processor,\" The VLDB journal, 2009."},{"key":"e_1_3_2_1_12_1","doi-asserted-by":"publisher","DOI":"10.1109\/TBDATA.2016.2624274"},{"key":"e_1_3_2_1_13_1","volume-title":"How soccer players would do stream joins,\" in Proc. of the 2011 ACM SIGMOD Int'l Conf. on Management of data","author":"Teubner J.","year":"2011","unstructured":"J. Teubner and R. Mueller, \"How soccer players would do stream joins,\" in Proc. of the 2011 ACM SIGMOD Int'l Conf. on Management of data, 2011."},{"key":"e_1_3_2_1_14_1","unstructured":"\"Apache Storm \" http:\/\/storm.apache.org accessed:2024-03-14."},{"key":"e_1_3_2_1_15_1","unstructured":"\"Liebre SPE \" https:\/\/github.com\/vincenzo-gulisano\/Liebre accessed:2024-03-14."},{"key":"e_1_3_2_1_16_1","first-page":"214","volume-title":"The role of event-time order in data streaming analysis,\" in Proceedings of the 14th ACM International Conference on Distributed and Event-based Systems","author":"Gulisano V.","year":"2020","unstructured":"V. Gulisano, D. Palyvos-Giannas, B. Havers, and M. Papatriantafilou, \"The role of event-time order in data streaming analysis,\" in Proceedings of the 14th ACM International Conference on Distributed and Event-based Systems, 2020, pp. 214--217."},{"key":"e_1_3_2_1_17_1","volume-title":"WikiAtomicEdits: A Multilingual Corpus of Wikipedia Edits for Modeling Language and Discourse,\" in Proc. of EMNLP","author":"Faruqui M.","year":"2018","unstructured":"M. Faruqui, E. Pavlick, I. Tenney, and D. Das, \"WikiAtomicEdits: A Multilingual Corpus of Wikipedia Edits for Modeling Language and Discourse,\" in Proc. of EMNLP, 2018."},{"key":"e_1_3_2_1_18_1","volume-title":"Detection, localisation and tracking of pallets using machine learning techniques and 2d range data,\" arXiv preprint arXiv:1803.11254","author":"Mohamed I. S.","year":"2018","unstructured":"I. S. Mohamed, A. Capitanelli, F. Mastrogiovanni, S. Rovetta, and R. Zaccaria, \"Detection, localisation and tracking of pallets using machine learning techniques and 2d range data,\" arXiv preprint arXiv:1803.11254, 2018."},{"key":"e_1_3_2_1_19_1","doi-asserted-by":"publisher","DOI":"10.1016\/j.dib.2019.103837"},{"key":"e_1_3_2_1_20_1","unstructured":"\"Apache Flink - Rework streaming iteration flow control \" https:\/\/issues.apache.org\/jira\/browse\/FLINK-2497?jql=project%20%3D%20FLINK%20AND%20text%20~%20%22loop%20deadlock%22 accessed:2023-1-27."},{"key":"e_1_3_2_1_21_1","first-page":"191","volume-title":"Performance modeling of stream joins,\" in Proceedings of the 11th ACM International Conference on Distributed and Event-based Systems","author":"Gulisano V.","year":"2017","unstructured":"V. Gulisano, A. V. Papadopoulos, Y. Nikolakopoulos, M. Papatriantafilou, and P. Tsigas, \"Performance modeling of stream joins,\" in Proceedings of the 11th ACM International Conference on Distributed and Event-based Systems, 2017, pp. 191--202."},{"key":"e_1_3_2_1_22_1","doi-asserted-by":"publisher","DOI":"10.1145\/3464298.3493407"},{"key":"e_1_3_2_1_23_1","doi-asserted-by":"publisher","DOI":"10.1145\/2934664"},{"issue":"4","key":"e_1_3_2_1_24_1","first-page":"28","article-title":"Apache flink\u2122: Stream and batch processing in a single engine","volume":"38","author":"Carbone P.","year":"2015","unstructured":"P. Carbone, A. Katsifodimos, S. Ewen, V. Markl, S. Haridi, and K. Tzoumas, \"Apache flink\u2122: Stream and batch processing in a single engine,\" IEEE Data Engineering Bulletin, vol. 38, no. 4, pp. 28--38, 2015.","journal-title":"IEEE Data Engineering Bulletin"},{"key":"e_1_3_2_1_25_1","doi-asserted-by":"publisher","DOI":"10.1145\/2588555.2595641"},{"key":"e_1_3_2_1_26_1","doi-asserted-by":"publisher","DOI":"10.1145\/2723372.2742788"},{"key":"e_1_3_2_1_27_1","volume-title":"Manning","author":"Bejeck B.","year":"2018","unstructured":"B. Bejeck, Kafka Streams in Action: Real-time apps and microservices with the Kafka Streams API. Manning, 2018."},{"key":"e_1_3_2_1_28_1","doi-asserted-by":"publisher","DOI":"10.14778\/3137765.3137770"},{"key":"e_1_3_2_1_29_1","first-page":"507","volume-title":"ESOP 2010, Held as Part of the Joint European Conferences on Theory and Practice of Software, ETAPS 2010, Paphos, Cyprus, March 20--28, 2010. Proceedings 19","author":"Soul\u00e9 R.","year":"2010","unstructured":"R. Soul\u00e9, M. Hirzel, R. Grimm, B. Gedik, H. Andrade, V. Kumar, and K.-L. Wu, \"A universal calculus for stream processing languages,\" in Programming Languages and Systems: 19th European Symposium on Programming, ESOP 2010, Held as Part of the Joint European Conferences on Theory and Practice of Software, ETAPS 2010, Paphos, Cyprus, March 20--28, 2010. Proceedings 19. Springer, 2010, pp. 507--528."},{"key":"e_1_3_2_1_30_1","doi-asserted-by":"publisher","DOI":"10.1007\/s00778-004-0147-z"},{"key":"e_1_3_2_1_31_1","doi-asserted-by":"publisher","DOI":"10.14778\/1920841.1920874"},{"key":"e_1_3_2_1_32_1","doi-asserted-by":"publisher","DOI":"10.1186\/s40537-017-0072-9"},{"key":"e_1_3_2_1_33_1","volume-title":"Watermarks in stream processing systems: Semantics and comparative analysis of apache flink and google cloud dataflow,\" Proceedings of the VLDB Endowment, no. 3","author":"Akidau T.","year":"2020","unstructured":"T. Akidau, E. Begoli, S. Chernyak, F. Hueske, K. Knight, K. Knowles, D. Mills, and D. Sotolongo, \"Watermarks in stream processing systems: Semantics and comparative analysis of apache flink and google cloud dataflow,\" Proceedings of the VLDB Endowment, no. 3, 2020."},{"key":"e_1_3_2_1_34_1","doi-asserted-by":"publisher","DOI":"10.1145\/3477602"},{"key":"e_1_3_2_1_35_1","doi-asserted-by":"publisher","DOI":"10.1145\/3242153.3242155"},{"key":"e_1_3_2_1_36_1","first-page":"49","volume-title":"ATC'14","author":"Fernandez R. C.","year":"2014","unstructured":"R. C. Fernandez, M. Migliavacca, E. Kalyvianaki, and P. Pietzuch, \"Making state explicit for imperative big data processing,\" in Proc of the USENIX Annual Technical Conf, ser. ATC'14. USENIX Assoc., 2014, p. 49--60."},{"key":"e_1_3_2_1_37_1","volume-title":"A model and survey of distributed data-intensive systems,\" ACM Comput. Surv","author":"Margara A.","unstructured":"A. Margara, G. Cugola, N. Felicioni, and S. Cilloni, \"A model and survey of distributed data-intensive systems,\" ACM Comput. Surv., vol. 56, no. 1, 2023."},{"key":"e_1_3_2_1_38_1","doi-asserted-by":"publisher","DOI":"10.1145\/2517349.2522738"},{"key":"e_1_3_2_1_39_1","first-page":"113","volume-title":"NSDI'11","author":"Murray D. G.","year":"2011","unstructured":"D. G. Murray, M. Schwarzkopf, C. Smowton, S. Smith, A. Madhavapeddy, and S. Hand, \"Ciel: A universal execution engine for distributed data-flow computing,\" in Proc of the Conf on Networked Systems Design and Implementation, ser. NSDI'11. USENIX Assoc., 2011, p. 113--126."},{"key":"e_1_3_2_1_40_1","doi-asserted-by":"publisher","DOI":"10.1016\/j.jpdc.2020.03.003"},{"key":"e_1_3_2_1_41_1","doi-asserted-by":"publisher","DOI":"10.14778\/2733004.2733048"},{"key":"e_1_3_2_1_42_1","doi-asserted-by":"publisher","DOI":"10.1145\/2187671.2187677"},{"key":"e_1_3_2_1_43_1","doi-asserted-by":"publisher","DOI":"10.1007\/s00778-019-00557-w"},{"key":"e_1_3_2_1_44_1","doi-asserted-by":"publisher","DOI":"10.1145\/3485463"},{"key":"e_1_3_2_1_45_1","doi-asserted-by":"publisher","DOI":"10.1145\/1619258.1619264"},{"key":"e_1_3_2_1_46_1","doi-asserted-by":"publisher","DOI":"10.1145\/2528412"},{"key":"e_1_3_2_1_47_1","doi-asserted-by":"publisher","DOI":"10.1145\/3408895"},{"key":"e_1_3_2_1_48_1","doi-asserted-by":"publisher","DOI":"10.14778\/3603581.3603604"}],"event":{"name":"Middleware '24: 25th International Middleware Conference","location":"Hong Kong Hong Kong","acronym":"Middleware '24","sponsor":["IFIP","Usenix"]},"container-title":["Proceedings of the 25th International Middleware Conference"],"original-title":[],"link":[{"URL":"https:\/\/dl.acm.org\/doi\/10.1145\/3652892.3654790","content-type":"unspecified","content-version":"vor","intended-application":"text-mining"},{"URL":"https:\/\/dl.acm.org\/doi\/pdf\/10.1145\/3652892.3654790","content-type":"unspecified","content-version":"vor","intended-application":"similarity-checking"}],"deposited":{"date-parts":[[2025,6,18]],"date-time":"2025-06-18T22:53:56Z","timestamp":1750287236000},"score":1,"resource":{"primary":{"URL":"https:\/\/dl.acm.org\/doi\/10.1145\/3652892.3654790"}},"subtitle":[],"short-title":[],"issued":{"date-parts":[[2024,12,2]]},"references-count":48,"alternative-id":["10.1145\/3652892.3654790","10.1145\/3652892"],"URL":"https:\/\/doi.org\/10.1145\/3652892.3654790","relation":{},"subject":[],"published":{"date-parts":[[2024,12,2]]},"assertion":[{"value":"2024-12-02","order":3,"name":"published","label":"Published","group":{"name":"publication_history","label":"Publication History"}}]}}