{"status":"ok","message-type":"work","message-version":"1.0.0","message":{"indexed":{"date-parts":[[2026,6,19]],"date-time":"2026-06-19T16:11:56Z","timestamp":1781885516494,"version":"3.54.5"},"reference-count":89,"publisher":"Springer Science and Business Media LLC","issue":"2","license":[{"start":{"date-parts":[[2023,9,27]],"date-time":"2023-09-27T00:00:00Z","timestamp":1695772800000},"content-version":"tdm","delay-in-days":0,"URL":"https:\/\/creativecommons.org\/licenses\/by\/4.0"},{"start":{"date-parts":[[2023,9,27]],"date-time":"2023-09-27T00:00:00Z","timestamp":1695772800000},"content-version":"vor","delay-in-days":0,"URL":"https:\/\/creativecommons.org\/licenses\/by\/4.0"}],"funder":[{"DOI":"10.13039\/501100001381","name":"National Research Foundation Singapore","doi-asserted-by":"publisher","award":["FCP-SUTD-RG-2021-005"],"award-info":[{"award-number":["FCP-SUTD-RG-2021-005"]}],"id":[{"id":"10.13039\/501100001381","id-type":"DOI","asserted-by":"publisher"}]},{"DOI":"10.13039\/501100007040","name":"Singapore University of Technology and Design","doi-asserted-by":"publisher","award":["SRT3IS21164"],"award-info":[{"award-number":["SRT3IS21164"]}],"id":[{"id":"10.13039\/501100007040","id-type":"DOI","asserted-by":"publisher"}]},{"DOI":"10.13039\/501100001659","name":"Deutsche Forschungsgemeinschaft","doi-asserted-by":"publisher","award":["MA4662-5"],"award-info":[{"award-number":["MA4662-5"]}],"id":[{"id":"10.13039\/501100001659","id-type":"DOI","asserted-by":"publisher"}]},{"DOI":"10.13039\/501100010571","name":"Bundesministerium f\u00fcr Bildung, Wissenschaft, Forschung und Technologie","doi-asserted-by":"publisher","award":["01IS18025A"],"award-info":[{"award-number":["01IS18025A"]}],"id":[{"id":"10.13039\/501100010571","id-type":"DOI","asserted-by":"publisher"}]},{"DOI":"10.13039\/501100010571","name":"Bundesministerium f\u00fcr Bildung, Wissenschaft, Forschung und Technologie","doi-asserted-by":"publisher","award":["01IS18037A"],"award-info":[{"award-number":["01IS18037A"]}],"id":[{"id":"10.13039\/501100010571","id-type":"DOI","asserted-by":"publisher"}]}],"content-domain":{"domain":["link.springer.com"],"crossmark-restriction":false},"short-container-title":["The VLDB Journal"],"published-print":{"date-parts":[[2024,3]]},"abstract":"<jats:title>Abstract<\/jats:title><jats:p>Transactional stream processing (TSP) strives to create a cohesive model that merges the advantages of both transactional and stream-oriented guarantees. Over the past decade, numerous endeavors have contributed to the evolution of TSP solutions, uncovering similarities and distinctions among them. Despite these advances, a universally accepted standard approach for integrating transactional functionality with stream processing remains to be established. Existing TSP solutions predominantly concentrate on specific application characteristics and involve complex design trade-offs. This survey intends to introduce TSP and present our perspective on its future progression. Our primary goals are twofold: to provide insights into the diverse TSP requirements and methodologies, and to inspire the design and development of groundbreaking TSP systems.<\/jats:p>","DOI":"10.1007\/s00778-023-00814-z","type":"journal-article","created":{"date-parts":[[2023,9,27]],"date-time":"2023-09-27T11:02:08Z","timestamp":1695812528000},"page":"451-479","update-policy":"https:\/\/doi.org\/10.1007\/springer_crossmark_policy","source":"Crossref","is-referenced-by-count":16,"title":["A survey on transactional stream processing"],"prefix":"10.1007","volume":"33","author":[{"ORCID":"https:\/\/orcid.org\/0000-0002-9927-6925","authenticated-orcid":false,"given":"Shuhao","family":"Zhang","sequence":"first","affiliation":[],"role":[{"vocabulary":"crossref","role":"author"}]},{"given":"Juan","family":"Soto","sequence":"additional","affiliation":[],"role":[{"vocabulary":"crossref","role":"author"}]},{"given":"Volker","family":"Markl","sequence":"additional","affiliation":[],"role":[{"vocabulary":"crossref","role":"author"}]}],"member":"297","published-online":{"date-parts":[[2023,9,27]]},"reference":[{"key":"814_CR1","first-page":"277","volume":"5","author":"DJ Abadi","year":"2005","unstructured":"Abadi, D.J., Ahmad, Y., Balazinska, M., Cetintemel, U., Cherniack, M., Hwang, J.H., Lindner, W., Maskey, A., Rasin, A., Ryvkina, E., et al.: The design of the borealis stream processing engine. CIDR\u201905 5, 277\u2013289 (2005)","journal-title":"CIDR\u201905"},{"issue":"2","key":"814_CR2","doi-asserted-by":"publisher","first-page":"120","DOI":"10.1007\/s00778-003-0095-z","volume":"12","author":"DJ Abadi","year":"2003","unstructured":"Abadi, D.J., Carney, D., \u00c7etintemel, U., Cherniack, M., Convey, C., Lee, S., Stonebraker, M., Tatbul, N., Zdonik, S.: Aurora: a new model and architecture for data stream management. VLDB J. 12(2), 120\u2013139 (2003). https:\/\/doi.org\/10.1007\/s00778-003-0095-z","journal-title":"VLDB J."},{"key":"814_CR3","doi-asserted-by":"publisher","unstructured":"Affetti, L., Margara, A., Cugola, G.: Flowdb: Integrating stream processing and consistent state management. In: Proceedings of the 11th ACM International Conference on Distributed and Event-based Systems, Debs \u201917, pp. 134\u2013145. Acm, New York, NY, USA (2017). https:\/\/doi.org\/10.1145\/3093742.3093929","DOI":"10.1145\/3093742.3093929"},{"key":"814_CR4","doi-asserted-by":"publisher","unstructured":"Affetti, L., Margara, A., Cugola, G.: Tspoon: Transactions on a stream processor. J. Parallel Distrib. Comput. 140, 65\u201379 (2020) https:\/\/doi.org\/10.1016\/j.jpdc.2020.03.003. www.sciencedirect.com\/science\/article\/pii\/S0743731518305082","DOI":"10.1016\/j.jpdc.2020.03.003"},{"issue":"12","key":"814_CR5","doi-asserted-by":"publisher","first-page":"1890","DOI":"10.14778\/3352063.3352092","volume":"12","author":"A Akhter","year":"2019","unstructured":"Akhter, A., Fragkoulis, M., Katsifodimos, A.: Stateful functions as a service in action. Proc. VLDB Endow. 12(12), 1890\u20131893 (2019)","journal-title":"Proc. VLDB Endow."},{"key":"814_CR6","doi-asserted-by":"publisher","unstructured":"Akidau, T., Balikov, A., Bekiro\u011flu, K., Chernyak, S., Haberman, J., Lax, R., McVeety, S., Mills, D., Nordstrom, P., Whittle, S.: Millwheel: Fault-tolerant stream processing at internet scale. Proc. VLDB Endow. 6(11), 1033\u20131044 (2013). https:\/\/doi.org\/10.14778\/2536222.2536229","DOI":"10.14778\/2536222.2536229"},{"issue":"2","key":"814_CR7","doi-asserted-by":"publisher","first-page":"121","DOI":"10.1007\/s00778-004-0147-z","volume":"15","author":"A Arasu","year":"2006","unstructured":"Arasu, A., Babu, S., Widom, J.: The CQL continuous query language: semantic foundations and query execution. VLDB J. 15(2), 121\u2013142 (2006). https:\/\/doi.org\/10.1007\/s00778-004-0147-z","journal-title":"VLDB J."},{"key":"814_CR8","doi-asserted-by":"publisher","unstructured":"Armbrust, M., Das, T., Sun, L., Yavuz, B., Zhu, S., Murthy, M., Torres, J., van Hovell, H., Ionescu, A., \u0141uszczak, A., \u015awitakowski, M., Szafra\u0144ski, M., Li, X., Ueshin, T., Mokhtar, M., Boncz, P., Ghodsi, A., Paranjpye, S., Senster, P., Xin, R., Zaharia, M.: Delta lake: high-performance acid table storage over cloud object stores. Proc. VLDB Endow. 13(12), 3411\u20133424 (2020). https:\/\/doi.org\/10.14778\/3415478.3415560","DOI":"10.14778\/3415478.3415560"},{"key":"814_CR9","doi-asserted-by":"publisher","unstructured":"Ayad, A.M., Naughton, J.F.: Static optimization of conjunctive queries with sliding windows over infinite streams. In: Proceedings of the 2004 ACM SIGMOD International Conference on Management of Data, SIGMOD \u201904, pp. 419\u2013430. Association for Computing Machinery, New York, NY, USA (2004). https:\/\/doi.org\/10.1145\/1007568.1007616","DOI":"10.1145\/1007568.1007616"},{"key":"814_CR10","doi-asserted-by":"publisher","unstructured":"Babcock, B., Babu, S., Datar, M., Motwani, R., Widom, J.: Models and issues in data stream systems. In: Proceedings of the Twenty-First ACM SIGMOD-SIGACT-SIGART Symposium on Principles of Database Systems, PODS \u201902, pp. 1\u201316. Association for Computing Machinery, New York, NY, USA (2002). https:\/\/doi.org\/10.1145\/543613.543615","DOI":"10.1145\/543613.543615"},{"key":"814_CR11","doi-asserted-by":"crossref","unstructured":"Balazinska, M., Balakrishnan, H., Madden, S., Stonebraker, M.: Fault-tolerance in the borealis distributed stream processing system. In: Proceedings of the 2005 ACM SIGMOD International Conference on Management of Data, pp. 13\u201324 (2005)","DOI":"10.1145\/1066157.1066160"},{"key":"814_CR12","volume-title":"Principles of Transaction Processing: For the Systems Professional","author":"P Bernstein","year":"1997","unstructured":"Bernstein, P., Newcomer, E.: Principles of Transaction Processing: For the Systems Professional. Morgan Kaufmann Publishers Inc., San Francisco, CA, USA (1997)"},{"issue":"2","key":"814_CR13","doi-asserted-by":"publisher","first-page":"185","DOI":"10.1145\/356842.356846","volume":"13","author":"PA Bernstein","year":"1981","unstructured":"Bernstein, P.A., Goodman, N.: Concurrency control in distributed database systems. ACM Comput. Surv. 1981 13(2), 185\u2013221 (1981). https:\/\/doi.org\/10.1145\/356842.356846","journal-title":"ACM Comput. Surv. 1981"},{"key":"814_CR14","doi-asserted-by":"publisher","unstructured":"Botan, I., Alonso, G., Fischer, P.M., Kossmann, D., Tatbul, N.: Flexible and scalable storage management for data-intensive stream processing. In: Proceedings of the 12th International Conference on Extending Database Technology: Advances in Database Technology, EDBT \u201909, pp. 934\u2013945. Association for Computing Machinery, New York, NY, USA (2009). https:\/\/doi.org\/10.1145\/1516360.1516467","DOI":"10.1145\/1516360.1516467"},{"key":"814_CR15","doi-asserted-by":"publisher","DOI":"10.1007\/978-3-642-14559-9_2","author":"I Botan","year":"2009","unstructured":"Botan, I., Cho, Y., Derakhshan, R., Dindar, N., Haas, L., Kim, K., Lee, C., Mundada, G., Shan, M.C., Tatbul, N., Yan, Y., Yun, B., Zhang, J.: Design and implementation of the maxstream federated stream processing architecture. Tech. Rep. ETH Zurich Dep. Comput. Sci. (2009). https:\/\/doi.org\/10.1007\/978-3-642-14559-9_2","journal-title":"Tech. Rep. ETH Zurich Dep. Comput. Sci."},{"key":"814_CR16","doi-asserted-by":"publisher","unstructured":"Botan, I., Fischer, P.M., Kossmann, D., Tatbul, N.: Transactional stream processing. In: Proceedings of the 15th International Conference on Extending Database Technology, EDBT \u201912, pp. 204\u2013215. Acm, New York, NY, USA (2012). https:\/\/doi.org\/10.1145\/2247596.2247622","DOI":"10.1145\/2247596.2247622"},{"key":"814_CR17","doi-asserted-by":"publisher","unstructured":"Braun, L., Etter, T., Gasparis, G., Kaufmann, M., Kossmann, D., Widmer, D., Avitzur, A., Iliopoulos, A., Levy, E., Liang, N.: Analytics in motion: High performance event-processing and real-time analytics in the same database. In: Proceedings of the 2015 ACM SIGMOD International Conference on Management of Data, SIGMOD \u201915, pp. 251\u2013264. Association for Computing Machinery, New York, NY, USA (2015). https:\/\/doi.org\/10.1145\/2723372.2742783","DOI":"10.1145\/2723372.2742783"},{"key":"814_CR18","doi-asserted-by":"publisher","unstructured":"Brito, A., Fetzer, C., Sturzrehm, H., Felber, P.: Speculative out-of-order event processing with software transaction memory. In: R.\u00a0Baldoni (ed.) Proceedings of the Second International Conference on Distributed Event-Based Systems, DEBS 2008. Rome, Italy, July 1\u20134, 2008, ACM International Conference Proceeding Series 332, 265\u2013275 (2008). https:\/\/doi.org\/10.1145\/1385989.1386023. (ACM)","DOI":"10.1145\/1385989.1386023"},{"key":"814_CR19","doi-asserted-by":"publisher","unstructured":"Carbone, P., Ewen, S., F\u00f3ra, G., Haridi, S., Richter, S., Tzoumas, K.: State management in apache flink: Consistent stateful distributed stream processing. Proc. VLDB Endow. 10(12), 1718\u20131729 (2017). https:\/\/doi.org\/10.14778\/3137765.3137777","DOI":"10.14778\/3137765.3137777"},{"key":"814_CR20","doi-asserted-by":"publisher","unstructured":"Carbone, P., Fragkoulis, M., Kalavri, V., Katsifodimos, A.: Beyond analytics: The evolution of stream processing systems. In: Proceedings of the 2020 ACM SIGMOD International Conference on Management of Data, SIGMOD \u201920, pp. 2651\u20132658. Association for Computing Machinery, New York, NY, USA (2020). https:\/\/doi.org\/10.1145\/3318464.3383131","DOI":"10.1145\/3318464.3383131"},{"issue":"4","key":"814_CR21","first-page":"1","volume":"36","author":"P Carbone","year":"2015","unstructured":"Carbone, P., Katsifodimos, A., Ewen, S., Markl, V., Haridi, S., Tzoumas, K.: Apache flink: Stream and batch processing in a single engine. Bull. IEEE Comput. Soc. Techn. Comm. Data Eng. 36(4), 1\u201312 (2015)","journal-title":"Bull. IEEE Comput. Soc. Techn. Comm. Data Eng."},{"issue":"13","key":"814_CR22","doi-asserted-by":"publisher","first-page":"1633","DOI":"10.14778\/2733004.2733048","volume":"7","author":"U Cetintemel","year":"2014","unstructured":"Cetintemel, U., Du, J., Kraska, T., Madden, S., Maier, D., Meehan, J., Pavlo, A., Stonebraker, M., Sutherland, E., Tatbul, N., Tufte, K., Wang, H., Zdonik, S.: S-store: A streaming newsql system for big velocity applications. Proc. VLDB Endow. 7(13), 1633\u20131636 (2014). https:\/\/doi.org\/10.14778\/2733004.2733048","journal-title":"Proc. VLDB Endow."},{"key":"814_CR23","doi-asserted-by":"crossref","unstructured":"Chandrasekaran, S., Franklin, M.: Remembrance of streams past: Overload-sensitive management of archived streams. In: VLDB (2004)","DOI":"10.1016\/B978-012088469-8.50033-4"},{"key":"814_CR24","unstructured":"Chang, F., Dean, J., Ghemawat, S., Hsieh, W.C., Wallach, D.A., Burrows, M., Chandra, T., Fikes, A., Gruber, R.E.: Bigtable: a distributed storage system for structured data. In: 7th USENIX Symposium on Operating Systems Design and Implementation (OSDI), pp. 205\u2013218 (2006)"},{"issue":"2","key":"814_CR25","doi-asserted-by":"publisher","first-page":"1","DOI":"10.1145\/1365815.1365816","volume":"26","author":"F Chang","year":"2008","unstructured":"Chang, F., Dean, J., Ghemawat, S., Hsieh, W.C., Wallach, D.A., Burrows, M., Chandra, T., Fikes, A., Gruber, R.E.: Bigtable: a distributed storage system for structured data. ACM Trans. Comput. Syst. (TOCS) 26(2), 1\u201326 (2008)","journal-title":"ACM Trans. Comput. Syst. (TOCS)"},{"key":"814_CR26","doi-asserted-by":"crossref","unstructured":"Chen, H., Migliavacca, M.: Streamdb: A unified data management system for service-based cloud application. In: 2018 IEEE International Conference on Services Computing (SCC), pp. 169\u2013176. IEEE (2018)","DOI":"10.1109\/SCC.2018.00029"},{"key":"814_CR27","doi-asserted-by":"crossref","unstructured":"Chen, Q., Hsu, M.: Experience in extending query engine for continuous analytics. In: T.\u00a0Bach\u00a0Pedersen, M.K. Mohania, A.M. Tjoa (eds.) Data Warehousing and Knowledge Discovery, pp. 190\u2013202. Springer Berlin Heidelberg, Berlin, Heidelberg (2010)","DOI":"10.1007\/978-3-642-15105-7_15"},{"key":"814_CR28","doi-asserted-by":"crossref","unstructured":"Chen, Q., Hsu, M.: Query engine grid for executing sql streaming process. In: International Conference on Data Management in Grid and P2P Systems, pp. 95\u2013107. Springer (2011)","DOI":"10.1007\/978-3-642-22947-3_9"},{"key":"814_CR29","doi-asserted-by":"publisher","unstructured":"Chen, Q., Hsu, M., Zeller, H.: Experience in continuous analytics as a service (caaas). In: Proceedings of the 14th International Conference on Extending Database Technology, EDBT\/ICDT \u201911, pp. 509\u2013514. Association for Computing Machinery, New York, NY, USA (2011). https:\/\/doi.org\/10.1145\/1951365.1951426","DOI":"10.1145\/1951365.1951426"},{"key":"814_CR30","unstructured":"Conway, N.: Cisc 499*: Transactions and data stream processing. Apr 6, 28 (2008)"},{"key":"814_CR31","unstructured":"Coral8, inc, http:\/\/www.coral8.com\/ (2008)"},{"issue":"3","key":"814_CR32","doi-asserted-by":"publisher","first-page":"1","DOI":"10.1145\/2491245","volume":"31","author":"JC Corbett","year":"2013","unstructured":"Corbett, J.C., Dean, J., Epstein, M., Fikes, A., Frost, C., Furman, J.J., Ghemawat, S., Gubarev, A., Heiser, C., Hochschild, P., et al.: Spanner: Google\u2019s globally distributed database. ACM Trans. Comput. Syst. (TOCS) 31(3), 1\u201322 (2013)","journal-title":"ACM Trans. Comput. Syst. (TOCS)"},{"key":"814_CR33","unstructured":"Data Artisans Streaming Ledger Serializable ACID Transactions on Streaming Data, https:\/\/www.data-artisans.com\/blog\/serializable-acid-transactions-on-streaming-data (2018)"},{"key":"814_CR34","unstructured":"Franklin, M., Krishnamurthy, S., Conway, N., Li, A., Russakovsky, A., Thombre, N.: Continuous analytics: Rethinking query processing in a network-effect world. In: CIDR (2009)"},{"issue":"3","key":"814_CR35","doi-asserted-by":"publisher","first-page":"249","DOI":"10.1145\/38714.38742","volume":"16","author":"H Garcia-Molina","year":"1987","unstructured":"Garcia-Molina, H., Salem, K.: Sagas. SIGMOD Rec. 16(3), 249\u2013259 (1987). https:\/\/doi.org\/10.1145\/38714.38742","journal-title":"SIGMOD Rec."},{"key":"814_CR36","doi-asserted-by":"publisher","first-page":"608","DOI":"10.1007\/11687238_37","volume-title":"Advances in Database Technology - EDBT 2006","author":"L Golab","year":"2006","unstructured":"Golab, L., Bijay, K.G., \u00d6zsu, M.T.: On concurrency control in sliding window queries over data streams. In: Ioannidis, Y., Scholl, M.H., Schmidt, J.W., Matthes, F., Hatzopoulos, M., Boehm, K., Kemper, A., Grust, T., Boehm, C. (eds.) Advances in Database Technology - EDBT 2006, pp. 608\u2013626. Springer Berlin Heidelberg, , Berlin, Heidelberg (2006)"},{"key":"814_CR37","doi-asserted-by":"publisher","unstructured":"Golab, L., \u00d6zsu, M.T.: Update-pattern-aware modeling and processing of continuous queries. In: Proceedings of the 2005 ACM SIGMOD International Conference on Management of Data, SIGMOD \u201905, p. 658-669. Association for Computing Machinery, New York, NY, USA (2005). https:\/\/doi.org\/10.1145\/1066157.1066232","DOI":"10.1145\/1066157.1066232"},{"key":"814_CR38","unstructured":"G\u00f6tze, P., Sattler, K.: Snapshot isolation for transactional stream processing. In: EDBT (2019)"},{"key":"814_CR39","unstructured":"S., Group, et al.: Stream: the Stanford stream data manager. Tech. Rep., Stanford InfoLab (2003)"},{"key":"814_CR40","doi-asserted-by":"publisher","unstructured":"G\u00fcrgen, L., Roncancio, C., Labb\u00e9, C., Olive, V.: Transactional issues in sensor data management. In: Proceedings of the 3rd Workshop on Data Management for Sensor Networks: In Conjunction with VLDB 2006, DMSN \u201906, pp. 27\u201332. Association for Computing Machinery, New York, NY, USA (2006). https:\/\/doi.org\/10.1145\/1315903.1315910","DOI":"10.1145\/1315903.1315910"},{"key":"814_CR41","doi-asserted-by":"publisher","first-page":"3","DOI":"10.1007\/978-3-030-04780-1_1","volume-title":"Big Data Anal.","author":"Y Ishikawa","year":"2018","unstructured":"Ishikawa, Y., Sugiura, K., Takao, D.: Fault tolerant data stream processing in cooperation with OLTP engine. In: Mondal, A., Gupta, H., Srivastava, J., Reddy, P.K., Somayajulu, D. (eds.) Big Data Anal., pp. 3\u201314. Springer International Publishing, Cham (2018)"},{"key":"814_CR42","unstructured":"Katsifodimos, A., Fragkoulis, M.: Operational stream processing: Towards scalable and consistent event-driven applications. (2019)"},{"key":"814_CR43","doi-asserted-by":"publisher","unstructured":"Krishnamurthy, S., Franklin, M.J., Davis, J., Farina, D., Golovko, P., Li, A., Thombre, N.: Continuous analytics over discontinuous streams. In: Proceedings of the 2010 ACM SIGMOD International Conference on Management of Data, SIGMOD \u201910, pp. 1081\u20131092. Association for Computing Machinery, New York, NY, USA (2010). https:\/\/doi.org\/10.1145\/1807167.1807290","DOI":"10.1145\/1807167.1807290"},{"issue":"5","key":"814_CR44","doi-asserted-by":"publisher","first-page":"740","DOI":"10.14778\/3377369.3377381","volume":"13","author":"A Kumar","year":"2020","unstructured":"Kumar, A., Wang, Z., Ni, S., Li, C.: Amber: a debuggable dataflow system based on the actor model. Proc. VLDB Endow. 13(5), 740\u2013753 (2020). https:\/\/doi.org\/10.14778\/3377369.3377381","journal-title":"Proc. VLDB Endow."},{"issue":"2","key":"814_CR45","doi-asserted-by":"publisher","first-page":"1","DOI":"10.1145\/3341617.3326144","volume":"3","author":"D Kumar","year":"2019","unstructured":"Kumar, D., Li, J., Chandra, A., Sitaraman, R.: A TTL-based approach for data aggregation in geo-distributed streaming analytics. Proc. ACM Measure. Anal. Comput. Syst. 3(2), 1\u201327 (2019)","journal-title":"Proc. ACM Measure. Anal. Comput. Syst."},{"key":"814_CR46","doi-asserted-by":"publisher","unstructured":"Lee, G., Eo, J., Seo, J., Um, T., Chun, B.G.: High-performance stateful stream processing on solid-state drives. In: Proceedings of the 9th Asia-Pacific Workshop on Systems, APSys \u201918, pp. 9:1\u20139:7. ACM, New York, NY, USA (2018). https:\/\/doi.org\/10.1145\/3265723.3265739","DOI":"10.1145\/3265723.3265739"},{"key":"814_CR47","doi-asserted-by":"crossref","unstructured":"Liarou, E., Goncalves, R., Idreos, S.: Exploiting the power of relational databases for efficient stream processing. In: Proceedings of the 12th International Conference on Extending Database Technology: Advances in Database Technology, pp. 323\u2013334 (2009)","DOI":"10.1145\/1516360.1516398"},{"key":"814_CR48","unstructured":"Liarou, E., Kersten, M.: Datacell: Building a data stream engine on top of a relational database kernel. In: VLDB PhD Workshop (2009)"},{"key":"814_CR49","doi-asserted-by":"crossref","unstructured":"Madden, S., Franklin, M.J.: Fjording the stream: An architecture for queries over streaming sensor data. In: Proceedings 18th International Conference on Data Engineering, pp. 555\u2013566. IEEE (2002)","DOI":"10.1109\/ICDE.2002.994774"},{"key":"814_CR50","doi-asserted-by":"crossref","unstructured":"Mao, Y., Zhao, J., Zhang, S., Liu, H., Markl, V.: Morphstream: Adaptive scheduling for scalable transactional stream processing on multicores. In: Proceedings of the 2023 International Conference on Management of Data (SIGMOD), SIGMOD \u201923. Association for Computing Machinery, New York, NY, USA (2023)","DOI":"10.1145\/3588913"},{"key":"814_CR51","unstructured":"Marz, N.: Trident API Overview: https:\/\/github.com\/nathanmarz\/storm\/wiki\/"},{"key":"814_CR52","unstructured":"Meehan, J., Aslantas, C., Zdonik, S., Tatbul, N., Du, J.: Data ingestion for the connected world. In: CIDR (2017)"},{"issue":"13","key":"814_CR53","doi-asserted-by":"publisher","first-page":"2134","DOI":"10.14778\/2831360.2831367","volume":"8","author":"J Meehan","year":"2015","unstructured":"Meehan, J., Tatbul, N., Zdonik, S., Aslantas, C., Cetintemel, U., Du, J., Kraska, T., Madden, S., Maier, D., Pavlo, A., Stonebraker, M., Tufte, K., Wang, H.: S-store: streaming meets transaction processing. Proc. VLDB Endow. 8(13), 2134\u20132145 (2015). https:\/\/doi.org\/10.14778\/2831360.2831367","journal-title":"Proc. VLDB Endow."},{"issue":"6","key":"814_CR54","doi-asserted-by":"publisher","first-page":"183","DOI":"10.3390\/a15060183","volume":"15","author":"S Meftah","year":"2022","unstructured":"Meftah, S., Zhang, S., Veeravalli, B., Aung, K.M.M.: Revisiting the design of parallel stream joins on trusted execution environments. Algorithms 15(6), 183 (2022). https:\/\/doi.org\/10.3390\/a15060183","journal-title":"Algorithms"},{"key":"814_CR55","unstructured":"Motwani, R., Widom, J., Arasu, A., Babcock, B., Babu, S., Datar, M., Manku, G., Olston, C., Rosenstein, J., Varma, R.: Query processing, resource management, and approximation ina data stream management system. In: CIDR 2003. Stanford InfoLab (2002)"},{"key":"814_CR56","unstructured":"Ooi, B.C., Tan, K.L., Tung, A., Chen, G., Shou, M.Z., Xiao, X., Zhang, M.: Sense the physical, walkthrough the virtual, manage the metaverse: A data-centric perspective. arXiv preprint arXiv:2206.10326 (2022)"},{"key":"814_CR57","doi-asserted-by":"crossref","unstructured":"Oyamada, M., Kawashima, H., Kitagawa, H.: Efficient invocation of transaction sequences triggered by data streams. In: 2011 International Conference on P2P, Parallel, Grid, Cloud and Internet Computing, pp. 332\u2013337. IEEE (2011)","DOI":"10.1109\/3PGCIC.2011.63"},{"key":"814_CR58","doi-asserted-by":"publisher","unstructured":"Oyamada, M., Kawashima, H., Kitagawa, H.: Continuous query processing with concurrency control: Reading updatable resources consistently. In: Proceedings of the 28th Annual ACM Symposium on Applied Computing, SAC \u201913, pp. 788\u2013794. Association for Computing Machinery, New York, NY, USA (2013). https:\/\/doi.org\/10.1145\/2480362.2480514","DOI":"10.1145\/2480362.2480514"},{"issue":"2","key":"814_CR59","doi-asserted-by":"publisher","first-page":"54","DOI":"10.1145\/2505420.2505425","volume":"13","author":"M Oyamada","year":"2013","unstructured":"Oyamada, M., Kawashima, H., Kitagawa, H.: Data stream processing with concurrency control. SIGAPP Appl. Comput. Rev. 13(2), 54\u201365 (2013). https:\/\/doi.org\/10.1145\/2505420.2505425","journal-title":"SIGAPP Appl. Comput. Rev."},{"key":"814_CR60","unstructured":"Park, H., Zhai, S., Lu, L., Lin, F.X.: Streambox-tz: Secure stream analytics at the edge with trustzone. In: Proceedings of the 2019 USENIX Conference on Usenix Annual Technical Conference, USENIX ATC \u201919, pp. 537\u2013554. USENIX Association, USA (2019)"},{"key":"814_CR61","unstructured":"Pekhimenko, G., Guo, C., Jeon, M., Huang, P., Zhou, L.: $$\\{$$TerseCades$$\\}$$: Efficient data compression in stream processing. In: 2018 USENIX Annual Technical Conference (USENIX ATC 18), Usenix Atc \u201918, pp. 307\u2013320. USENIX Association, Berkeley, CA, USA (2018). http:\/\/dl.acm.org\/citation.cfm?id=3277355.3277385"},{"key":"814_CR62","doi-asserted-by":"publisher","unstructured":"Philipp, G., Stephan, B., Kai-Uwe, S.: An nvm-aware storage layout for analytical workloads. In: 2018 IEEE 34th International Conference on Data Engineering Workshops (ICDEW), pp. 110\u2013115 (2018). https:\/\/doi.org\/10.1109\/icdew.2018.00025","DOI":"10.1109\/icdew.2018.00025"},{"issue":"13","key":"814_CR63","doi-asserted-by":"publisher","first-page":"1367","DOI":"10.14778\/2733004.2733009","volume":"7","author":"M Poess","year":"2014","unstructured":"Poess, M., Rabl, T., Jacobsen, H.A., Caufield, B.: TPC-DI: the first industry benchmark for data integration. Proc. VLDB Endow. 7(13), 1367\u20131378 (2014). https:\/\/doi.org\/10.14778\/2733004.2733009","journal-title":"Proc. VLDB Endow."},{"key":"814_CR64","doi-asserted-by":"publisher","unstructured":"Ray, M., Lei, C., Rundensteiner, E.A.: Scalable pattern sharing on event streams*. In: Proceedings of the 2016 International Conference on Management of Data, SIGMOD \u201916, pp. 495\u2013510. Association for Computing Machinery, New York, NY, USA (2016). https:\/\/doi.org\/10.1145\/2882903.2882947","DOI":"10.1145\/2882903.2882947"},{"key":"814_CR65","unstructured":"Rocksdb. http:\/\/rocksdb.org\/"},{"key":"814_CR66","doi-asserted-by":"publisher","first-page":"123","DOI":"10.1007\/978-3-030-19274-7_10","volume-title":"Web Eng.","author":"OC Sahin","year":"2019","unstructured":"Sahin, O.C., Karagoz, P., Tatbul, N.: Streaming event detection in microblogs: Balancing accuracy and performance. In: Bakaev, M., Frasincar, F., Ko, I.Y. (eds.) Web Eng., pp. 123\u2013138. Springer International Publishing, Cham (2019)"},{"key":"814_CR67","unstructured":"Sattler, K.U.: Transactional stream processing on non-volatile memory (2019). https:\/\/www.tu-ilmenau.de\/dbis\/research\/active-projects\/transactional-stream-processing\/"},{"key":"814_CR68","doi-asserted-by":"publisher","unstructured":"Shahvarani, A., Jacobsen, H.A.: Parallel index-based stream join on a multicore cpu. In: Proceedings of the 2020 ACM SIGMOD International Conference on Management of Data, SIGMOD \u201920, pp. 2523\u20132537. Association for Computing Machinery, New York, NY, USA (2020). https:\/\/doi.org\/10.1145\/3318464.3380576","DOI":"10.1145\/3318464.3380576"},{"key":"814_CR69","doi-asserted-by":"publisher","unstructured":"Shaikh, S.A., Chao, D., Nishimura, K., Kitagawa, H.: Incremental continuous query processing over streams and relations with isolation guarantees. In: Proceedings, Part I, 27th International Conference on Database and Expert Systems Applications - Vol. 9827, DEXA 2016, pp. 321\u2013335. Springer-Verlag, Berlin, Heidelberg (2016). https:\/\/doi.org\/10.1007\/978-3-319-44403-1_20. https:\/\/doi.org\/10.1007\/978-3-319-44403-1%5F20","DOI":"10.1007\/978-3-319-44403-1_20"},{"issue":"104","key":"814_CR70","doi-asserted-by":"publisher","first-page":"104632","DOI":"10.1109\/ACCESS.2020.2999572","volume":"8","author":"SA Shaikh","year":"2020","unstructured":"Shaikh, S.A., Kitagawa, H.: Streamingcube: seamless integration of stream processing and olap analysis. IEEE Access 8(104), 104632\u2013104649 (2020). https:\/\/doi.org\/10.1109\/ACCESS.2020.2999572","journal-title":"IEEE Access"},{"key":"814_CR71","unstructured":"Shillaker, S., Pietzuch, P.: Faasm: Lightweight isolation for efficient stateful serverless computing. In: 2020 USENIX Annual Technical Conference (USENIX ATC 20), pp. 419\u2013433. USENIX Association (2020). https:\/\/www.usenix.org\/conference\/atc20\/presentation\/shillaker"},{"key":"814_CR72","doi-asserted-by":"publisher","unstructured":"Silvestre, P.F., Fragkoulis, M., Spinellis, D., Katsifodimos, A.: Clonos: Consistent Causal Recovery for Highly-Available Streaming Dataflows, p. 1637-1650. Association for Computing Machinery, New York, NY, USA (2021). https:\/\/doi.org\/10.1145\/3448016.3457320","DOI":"10.1145\/3448016.3457320"},{"issue":"4","key":"814_CR73","doi-asserted-by":"publisher","first-page":"42","DOI":"10.1145\/1107499.1107504","volume":"34","author":"M Stonebraker","year":"2005","unstructured":"Stonebraker, M., \u00c7etintemel, U., Zdonik, S.: The 8 requirements of real-time stream processing. SIGMOD Rec. 34(4), 42\u201347 (2005). https:\/\/doi.org\/10.1145\/1107499.1107504","journal-title":"SIGMOD Rec."},{"key":"814_CR74","unstructured":"Stonebraker, M., Madden, S., Abadi, D.J., Harizopoulos, S., Hachem, N., Helland, P.: The end of an architectural era: (it\u2019s time for a complete rewrite). In: Proc VLDB Endow. 2007"},{"key":"814_CR75","doi-asserted-by":"publisher","unstructured":"Tatbul, N.: Streaming data integration: Challenges and opportunities. In: 2010 IEEE 26th International Conference on Data Engineering Workshops (ICDEW 2010), pp. 155\u2013158 (2010). https:\/\/doi.org\/10.1109\/ICDEW.2010.5452751","DOI":"10.1109\/ICDEW.2010.5452751"},{"key":"814_CR76","doi-asserted-by":"publisher","unstructured":"Tatbul, N.: Transactional Stream Processing, pp. 4205\u20134211. Springer New York, New York, NY (2018). https:\/\/doi.org\/10.1007\/978-1-4614-8265-9_80704. https:\/\/doi.org\/10.1007\/978-1-4614-8265-9%5F80704","DOI":"10.1007\/978-1-4614-8265-9_80704"},{"key":"814_CR77","doi-asserted-by":"publisher","unstructured":"Theodorakis, G., Kounelis, F., Pietzuch, P., Pirk, H.: Scabbard: Single-node fault-tolerant stream processing. Proc. VLDB Endow. 15(2), 361\u2013374 (2021). https:\/\/doi.org\/10.14778\/3489496.3489515","DOI":"10.14778\/3489496.3489515"},{"key":"814_CR78","doi-asserted-by":"publisher","unstructured":"To, Q.C., Soto, J., Markl, V.: A survey of state management in big data processing systems. VLDB J. 27(6), 847\u2013872 (2018). https:\/\/doi.org\/10.1007\/s00778-018-0514-9","DOI":"10.1007\/s00778-018-0514-9"},{"key":"814_CR79","doi-asserted-by":"crossref","unstructured":"Verheijde, J., Karakoidas, V., Fragkoulis, M., Katsifodimos, A.: S-query: Opening the black box of internal stream processor state. In: 2022 IEEE 38th International Conference on Data Engineering (ICDE), pp. 1314\u20131327. IEEE (2022)","DOI":"10.1109\/ICDE53745.2022.00103"},{"key":"814_CR80","doi-asserted-by":"publisher","unstructured":"Vidyasankar, K.: Transactional properties of compositions of internet of things services. pp. 1\u20136 (2015). https:\/\/doi.org\/10.1109\/ISC2.2015.7366218","DOI":"10.1109\/ISC2.2015.7366218"},{"key":"814_CR81","doi-asserted-by":"publisher","first-page":"195","DOI":"10.1016\/j.procs.2016.04.116","volume":"83","author":"K Vidyasankar","year":"2016","unstructured":"Vidyasankar, K.: A transaction model for executions of compositions of internet of things services. Proc. Comput. Sci. 83, 195\u2013202 (2016). https:\/\/doi.org\/10.1016\/j.procs.2016.04.116","journal-title":"Proc. Comput. Sci."},{"key":"814_CR82","doi-asserted-by":"publisher","unstructured":"Vidyasankar, K.: Transactional composition of executions in stream processing. In: 2016 27th International Workshop on Database and Expert Systems Applications (DEXA), pp. 114\u2013118 (2016). https:\/\/doi.org\/10.1109\/DEXA.2016.037","DOI":"10.1109\/DEXA.2016.037"},{"key":"814_CR83","doi-asserted-by":"publisher","unstructured":"Vossen, G.: ACID Properties, pp. 1\u20133. Springer New York, New York, NY (2016). https:\/\/doi.org\/10.1007\/978-1-4899-7993-3_831-2. https:\/\/doi.org\/10.1007\/978-1-4899-7993-3%5F831-2","DOI":"10.1007\/978-1-4899-7993-3_831-2"},{"key":"814_CR84","doi-asserted-by":"publisher","unstructured":"Wang, D., Rundensteiner, E.A., Ellison III, R.T.: Active complex event processing over event streams. Proc. VLDB Endow. 4(10), 634\u2013645 (2011). https:\/\/doi.org\/10.14778\/2021017.2021021","DOI":"10.14778\/2021017.2021021"},{"key":"814_CR85","doi-asserted-by":"crossref","unstructured":"Winter, C., Schmidt, T., Neumann, T., Kemper, A.: Meet me halfway: split maintenance of continuous views. Proc. VLDB Endow. 13(11), 2620\u20132633 (2020)","DOI":"10.14778\/3407790.3407849"},{"key":"814_CR86","doi-asserted-by":"publisher","unstructured":"Wu, Y., Arulraj, J., Lin, J., Xian, R., Pavlo, A.: An empirical evaluation of in-memory multi-version concurrency control. Proc. VLDB Endow. 10(7), 781\u2013792 (2017). https:\/\/doi.org\/10.14778\/3067421.3067427","DOI":"10.14778\/3067421.3067427"},{"key":"814_CR87","unstructured":"Zeuch, S., Chaudhary, A., Monte, B.D., Gavriilidis, H., Giouroukis, D., Grulich, P.M., Bre\u00df, S., Traub, J., Markl, V.: The nebulastream platform for data and application management in the internet of things. In: CIDR 2020, 10th Conference on Innovative Data Systems Research, Amsterdam, The Netherlands, January 12\u201315, 2020, Online Proceedings. www.cidrdb.org (2020). http:\/\/cidrdb.org\/cidr2020\/papers\/p7-zeuch-cidr20.pdf"},{"key":"814_CR88","doi-asserted-by":"publisher","unstructured":"Zhang, S., Wu, Y., Zhang, F., He, B.: Towards concurrent stateful stream processing on multicore processors. In: 2020 IEEE 36th International Conference on Data Engineering (ICDE), pp. 1537\u20131548 (2020). https:\/\/doi.org\/10.1109\/ICDE48307.2020.00136","DOI":"10.1109\/ICDE48307.2020.00136"},{"issue":"4","key":"814_CR89","doi-asserted-by":"publisher","first-page":"18","DOI":"10.1145\/3385658.3385662","volume":"48","author":"S Zhang","year":"2020","unstructured":"Zhang, S., Zhang, F., Wu, Y., He, B., Johns, P.: Hardware-conscious stream processing: a survey. SIGMOD Rec. 48(4), 18\u201329 (2020). https:\/\/doi.org\/10.1145\/3385658.3385662","journal-title":"SIGMOD Rec."}],"container-title":["The VLDB Journal"],"original-title":[],"language":"en","link":[{"URL":"https:\/\/link.springer.com\/content\/pdf\/10.1007\/s00778-023-00814-z.pdf","content-type":"application\/pdf","content-version":"vor","intended-application":"text-mining"},{"URL":"https:\/\/link.springer.com\/article\/10.1007\/s00778-023-00814-z\/fulltext.html","content-type":"text\/html","content-version":"vor","intended-application":"text-mining"},{"URL":"https:\/\/link.springer.com\/content\/pdf\/10.1007\/s00778-023-00814-z.pdf","content-type":"application\/pdf","content-version":"vor","intended-application":"similarity-checking"}],"deposited":{"date-parts":[[2024,10,29]],"date-time":"2024-10-29T08:01:53Z","timestamp":1730188913000},"score":1,"resource":{"primary":{"URL":"https:\/\/link.springer.com\/10.1007\/s00778-023-00814-z"}},"subtitle":[],"short-title":[],"issued":{"date-parts":[[2023,9,27]]},"references-count":89,"journal-issue":{"issue":"2","published-print":{"date-parts":[[2024,3]]}},"alternative-id":["814"],"URL":"https:\/\/doi.org\/10.1007\/s00778-023-00814-z","relation":{},"ISSN":["1066-8888","0949-877X"],"issn-type":[{"value":"1066-8888","type":"print"},{"value":"0949-877X","type":"electronic"}],"subject":[],"published":{"date-parts":[[2023,9,27]]},"assertion":[{"value":"21 August 2022","order":1,"name":"received","label":"Received","group":{"name":"ArticleHistory","label":"Article History"}},{"value":"27 August 2023","order":2,"name":"revised","label":"Revised","group":{"name":"ArticleHistory","label":"Article History"}},{"value":"1 September 2023","order":3,"name":"accepted","label":"Accepted","group":{"name":"ArticleHistory","label":"Article History"}},{"value":"27 September 2023","order":4,"name":"first_online","label":"First Online","group":{"name":"ArticleHistory","label":"Article History"}},{"order":1,"name":"Ethics","group":{"name":"EthicsHeading","label":"Declarations"}},{"value":"The authors have no financial or proprietary interests in any material discussed in this article.","order":2,"name":"Ethics","group":{"name":"EthicsHeading","label":"Declarations"}}]}}