{"status":"ok","message-type":"work","message-version":"1.0.0","message":{"indexed":{"date-parts":[[2026,4,21]],"date-time":"2026-04-21T15:32:10Z","timestamp":1776785530747,"version":"3.51.2"},"reference-count":100,"publisher":"Springer Science and Business Media LLC","issue":"5","license":[{"start":{"date-parts":[[2023,2,17]],"date-time":"2023-02-17T00:00:00Z","timestamp":1676592000000},"content-version":"tdm","delay-in-days":0,"URL":"https:\/\/creativecommons.org\/licenses\/by\/4.0"},{"start":{"date-parts":[[2023,2,17]],"date-time":"2023-02-17T00:00:00Z","timestamp":1676592000000},"content-version":"vor","delay-in-days":0,"URL":"https:\/\/creativecommons.org\/licenses\/by\/4.0"}],"funder":[{"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"}]},{"DOI":"10.13039\/501100010571","name":"Bundesministerium f\u00fcr Bildung, Wissenschaft, Forschung und Technologie","doi-asserted-by":"publisher","award":["01IS17052"],"award-info":[{"award-number":["01IS17052"]}],"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":[[2023,9]]},"abstract":"<jats:title>Abstract<\/jats:title><jats:p>In this paper, we present the first comprehensive survey of window types for stream processing systems which have been presented in research and commercial systems. We cover publications from the most relevant conferences, journals, and system whitepapers on stream processing, windowing, and window aggregation which have been published over the last 20 years. For each window type, we provide detailed specifications, formal notations, synonyms, and use-case examples. We classify each window type according to categories that have been proposed in literature and describe the out-of-order processing. In addition, we examine academic, commercial, and open-source systems with respect to the window types that they support. Our survey offers a comprehensive overview that may serve as a guideline for the development of stream processing systems, window aggregation techniques, and frameworks that support a variety of window types.<\/jats:p>","DOI":"10.1007\/s00778-022-00778-6","type":"journal-article","created":{"date-parts":[[2023,2,17]],"date-time":"2023-02-17T16:52:30Z","timestamp":1676652750000},"page":"985-1011","update-policy":"https:\/\/doi.org\/10.1007\/springer_crossmark_policy","source":"Crossref","is-referenced-by-count":26,"title":["Survey of window types for aggregation in stream processing systems"],"prefix":"10.1007","volume":"32","author":[{"given":"Juliane","family":"Verwiebe","sequence":"first","affiliation":[]},{"ORCID":"https:\/\/orcid.org\/0000-0001-9497-2895","authenticated-orcid":false,"given":"Philipp M.","family":"Grulich","sequence":"additional","affiliation":[]},{"given":"Jonas","family":"Traub","sequence":"additional","affiliation":[]},{"given":"Volker","family":"Markl","sequence":"additional","affiliation":[]}],"member":"297","published-online":{"date-parts":[[2023,2,17]]},"reference":[{"key":"778_CR1","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. In: CIDR, vol.\u00a05, pp. 277\u2013289 (2005)"},{"issue":"2","key":"778_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., Cetintemel, 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)","journal-title":"VLDB J"},{"key":"778_CR3","doi-asserted-by":"crossref","unstructured":"Aggarwal, C.C., Philip, S.Y., Han, J., Wang, J.: A framework for clustering evolving data streams. In: VLDB, pp. 81\u201392 (2003)","DOI":"10.1016\/B978-012722442-8\/50016-1"},{"issue":"12","key":"778_CR4","first-page":"1792","volume":"8","author":"T Akidau","year":"2015","unstructured":"Akidau, T., Bradshaw, R., Chambers, C., Chernyak, S., Fern\u00e1ndez-Moctezuma, R.J., Lax, R., McVeety, S., Mills, D., Perry, F., Schmidt, E., Whittle, S.: The dataflow model: a practical approach to balancing correctness, latency, and cost in massive-scale, unbounded, out-of-order data processing. PVLDB 8(12), 1792\u20131803 (2015)","journal-title":"PVLDB"},{"key":"778_CR5","doi-asserted-by":"crossref","unstructured":"Ali, M., Chandramouli, B., Goldstein, J., Schindlauer, R.: The extensibility framework in microsoft streaminsight. In: ICDE, pp. 1242\u20131253. IEEE (2011)","DOI":"10.1109\/ICDE.2011.5767878"},{"issue":"2","key":"778_CR6","first-page":"1558","volume":"2","author":"MH Ali","year":"2009","unstructured":"Ali, M.H., Gerea, C., Raman, B.S., Sezgin, B., Tarnavski, T., Verona, T., Wang, P., Zabback, P., Ananthanarayan, A., Kirilov, A., et al.: Microsoft cep server and online behavioral targeting. PVLDB 2(2), 1558\u20131561 (2009)","journal-title":"PVLDB"},{"key":"778_CR7","unstructured":"Amazon Kinesis Data Analytics Documentation. https:\/\/docs.aws.amazon.com\/kinesis\/index.html. Accessed 20 Oct 2021"},{"key":"778_CR8","unstructured":"Amazon Kinesis Data Analytics Documentation. Windowed Queries. https:\/\/docs.aws.amazon.com\/kinesisanalytics\/latest\/dev\/windowed-sql.html. Accessed 20 Oct 10.2021"},{"key":"778_CR9","doi-asserted-by":"publisher","DOI":"10.1017\/CBO9781139058940","volume-title":"Fundamentals of Stream Processing: Application Design, Systems, and Analytics","author":"HCM Andrade","year":"2014","unstructured":"Andrade, H.C.M., Gedik, B., Tugara, D.S.: Fundamentals of Stream Processing: Application Design, Systems, and Analytics. Cambridge University Press, Cambridge (2014)"},{"key":"778_CR10","unstructured":"Apache Beam Documentation. Beam Capability Matrix. https:\/\/beam.apache.org\/documentation\/runners\/capability-matrix\/where-in-event-time\/. Accessed 18 Oct 2021"},{"key":"778_CR11","unstructured":"Apache Beam Documentation. Provided windowing functions. https:\/\/beam.apache.org\/documentation\/programming-guide\/#provided-windowing-functions. Accessed 18 Oct 2021"},{"key":"778_CR12","unstructured":"Apache Beam Documentation. Triggers. https:\/\/beam.apache.org\/documentation\/programming-guide\/#triggers. Accessed 18 Oct 2021"},{"key":"778_CR13","unstructured":"Apache Beam. https:\/\/beam.apache.org\/. Accessed 18 Oct 2021"},{"key":"778_CR14","doi-asserted-by":"crossref","unstructured":"Apache Flink Streaming Data API. Evictors. https:\/\/ci.apache.org\/projects\/flink\/flink-docs-release-1.13\/docs\/dev\/datastream\/operators\/windows\/#evictors. Accessed 18 Oct 2021","DOI":"10.1007\/978-3-319-63962-8_303-2"},{"key":"778_CR15","unstructured":"Apache Flink Documentation. Windows. https:\/\/ci.apache.org\/projects\/flink\/flink-docs-stable\/dev\/stream\/operators\/windows.html. Accessed 18 Oct 2021"},{"key":"778_CR16","doi-asserted-by":"crossref","unstructured":"Arasu, A., Babcock, B., Babu, S., Cieslewicz, J., Datar, M., Ito, K., Motwani, R., Srivastava, U., Widom, J.: Stream: The Stanford data stream management system. In: Data Stream Management, pp. 317\u2013336. Springer, Berlin (2016)","DOI":"10.1007\/978-3-540-28608-0_16"},{"key":"778_CR17","doi-asserted-by":"crossref","unstructured":"Arasu, A., Widom, J.: Resource sharing in continuous sliding-window aggregates. In: VLDB, pp. 336\u2013347 (2004)","DOI":"10.1016\/B978-012088469-8.50032-2"},{"key":"778_CR18","doi-asserted-by":"crossref","unstructured":"Begoli, E., Akidau, T., Hueske, F., Hyde, J., Knight, K., Knowles, K.: One SQL to rule them all\u2014an efficient and syntactically idiomatic approach to management of streams and tables. In: SIGMOD, pp. 1757\u20131772 (2019)","DOI":"10.1145\/3299869.3314040"},{"key":"778_CR19","unstructured":"Benson, L., Grulich, P.M., Zeuch, S., Markl, V., Rabl, T.: Disco: Efficient distributed window aggregation. In: EDBT, vol.\u00a020 (2020)"},{"key":"778_CR20","doi-asserted-by":"crossref","unstructured":"Bhatotia, P., Acar, U.A., Junqueira, F.P., Rodrigues, R.: Slider: incremental sliding window analytics. In: ACM\/IFIP\/USENIX Middleware, pp. 61\u201372 (2014)","DOI":"10.1145\/2663165.2663334"},{"key":"778_CR21","doi-asserted-by":"crossref","unstructured":"Bifet, A., Gavald\u00e0, R.: Learning from time-changing data with adaptive windowing. In: SIAM SDM, pp. 443\u2013448 (2007)","DOI":"10.1137\/1.9781611972771.42"},{"key":"778_CR22","unstructured":"Blee-Goldmann, A.S., Thomas, L.: Kip-450: sliding window aggregations in the DSL. https:\/\/cwiki.apache.org\/confluence\/display\/KAFKA\/KIP-450%3A+Sliding+Window+Aggregations+in+the+DSL (2020)"},{"issue":"1\u20132","key":"778_CR23","first-page":"232","volume":"3","author":"I Botan","year":"2010","unstructured":"Botan, I., Derakhshan, R., Dindar, N., Haas, L., Miller, R.J., Tatbul, N.: Secret: a model for analysis of the execution semantics of stream processing systems. PVLDB 3(1\u20132), 232\u2013243 (2010)","journal-title":"PVLDB"},{"key":"778_CR24","unstructured":"BOU, S., KITAGAWA, H., AMAGASA, T.: Cbix: incremental sliding-window aggregation for real-time analytics over out-of-order data streams (2018)"},{"key":"778_CR25","doi-asserted-by":"crossref","unstructured":"Bou, S., Kitagawa, H., Amagasa, T.: Cpix: real-time analytics over out-of-order data streams by incremental sliding-window aggregation. IEEE TKDE (2021)","DOI":"10.1109\/TKDE.2021.3054898"},{"key":"778_CR26","doi-asserted-by":"crossref","unstructured":"Cao, F., Estert, M., Qian, W., Zhou, A.: Density-based clustering over an evolving data stream with noise. In: SIAM SDM, pp. 328\u2013339. SIAM (2006)","DOI":"10.1137\/1.9781611972764.29"},{"key":"778_CR27","unstructured":"Carbone, P., Katsifodimos, A., Ewen, S., Markl, V., Haridi, S., Tzoumas, K.: Apache flink$$^{{\\rm TM}}$$: Stream and batch processing in a single engine. In: IEEE CS 36(4) (2015)"},{"key":"778_CR28","doi-asserted-by":"crossref","unstructured":"Carbone, P., Katsifodimos, A., Haridi, S.: Stream window aggregation semantics and optimization. In: Encyclopedia of Big Data Technologies (2019)","DOI":"10.1007\/978-3-319-77525-8_154"},{"key":"778_CR29","doi-asserted-by":"crossref","unstructured":"Carbone, P., Traub, J., Katsifodimos, A., Haridi, S., Markl, V.: Cutty: aggregate sharing for user-defined windows. In: CIKM, pp. 1201\u20131210 (2016)","DOI":"10.1145\/2983323.2983807"},{"key":"778_CR30","doi-asserted-by":"crossref","unstructured":"Carney, D., undefinedetintemel, U., Cherniack, M., Convey, C., Lee, S., Seidman, G., Stonebraker, M., Tatbul, N., Zdonik, S.: Monitoring streams: a new class of data management applications. In: Proceedings of the 28th International Conference on Very Large Data Bases, pp. 215\u2013226. VLDB Endowment (2002)","DOI":"10.1016\/B978-155860869-6\/50027-5"},{"issue":"4","key":"778_CR31","first-page":"401","volume":"8","author":"B Chandramouli","year":"2014","unstructured":"Chandramouli, B., Goldstein, J., Barnett, M., DeLine, R., Fisher, D., Platt, J.C., Terwilliger, J.F., Wernsing, J.: Trill: a high-performance incremental query processor for diverse analytics. PVLDB 8(4), 401\u2013412 (2014)","journal-title":"PVLDB"},{"key":"778_CR32","unstructured":"Chandramouli, B., Goldstein, J., Barnett, M., DeLine, R., Fisher, D., Platt, J.C., Terwilliger, J.F., Wernsing, J.: The trill incremental analytics engine. Technical report, MSR-TR-2014-54 (2014)"},{"key":"778_CR33","doi-asserted-by":"crossref","unstructured":"Chandrasekaran, S., Cooper, O., Deshpande, A., Franklin, M.J., Hellerstein, J.M., Hong, W., Krishnamurthy, S., Madden, S.R., Reiss, F., Shah, M.A.: Telegraphcq: continuous dataflow processing. In: SIGMOD, p. 668 (2003)","DOI":"10.1145\/872757.872857"},{"key":"778_CR34","unstructured":"Chen, J., Zhang, Q.: Bias-aware sketches. arXiv preprint arXiv:1610.07718 (2016)"},{"key":"778_CR35","doi-asserted-by":"crossref","unstructured":"Chen, Y., Dong, G., Han, J., Wah, B.W., Wang, J.: Multi-dimensional regression analysis of time-series data streams. In: VLDB, pp. 323\u2013334. Elsevier, Amsterdam (2002)","DOI":"10.1016\/B978-155860869-6\/50036-6"},{"issue":"1","key":"778_CR36","doi-asserted-by":"publisher","first-page":"58","DOI":"10.1016\/j.jalgor.2003.12.001","volume":"55","author":"G Cormode","year":"2005","unstructured":"Cormode, G., Muthukrishnan, S.: An improved data stream summary: the count-min sketch and its applications. J. Algorithms 55(1), 58\u201375 (2005)","journal-title":"J. Algorithms"},{"key":"778_CR37","doi-asserted-by":"crossref","unstructured":"Del\u00a0Monte, B., Zeuch, S., Rabl, T., Markl, V.: Rethinking stateful stream processing with rdma. In: SIGMOD (2022) (to appear)","DOI":"10.1145\/3514221.3517826"},{"key":"778_CR38","doi-asserted-by":"crossref","unstructured":"Flajolet, P., Fusy, \u00c9., Gandouet, O., Meunier, F.: Hyperloglog: the analysis of a near-optimal cardinality estimation algorithm. In: Discrete Mathematics and Theoretical Computer Science, pp. 137\u2013156 (2007)","DOI":"10.46298\/dmtcs.3545"},{"key":"778_CR39","doi-asserted-by":"crossref","unstructured":"Fu, M., Agrawal, A., Floratou, A., Graham, B., Jorgensen, A., Li, M., Lu, N., Ramasamy, K., Rao, S., Wang, C.: Twitter heron: towards extensible streaming engines. In: ICDE, pp. 1165\u20131172. IEEE (2017)","DOI":"10.1109\/ICDE.2017.161"},{"key":"778_CR40","unstructured":"Garofalakis, M.N., Gibbons, P.B.: Approximate query processing: taming the terabytes. In: VLDB vol. 10, pp. 645927\u2013672356 (2001)"},{"issue":"9","key":"778_CR41","first-page":"1105","volume":"44","author":"B Gedik","year":"2014","unstructured":"Gedik, B.: Generic windowing support for extensible stream processing systems. Softw.: Pract. Exp. 44(9), 1105\u20131128 (2014)","journal-title":"Softw.: Pract. Exp."},{"issue":"2","key":"778_CR42","doi-asserted-by":"publisher","first-page":"13","DOI":"10.1145\/376284.375665","volume":"30","author":"J Gehrke","year":"2001","unstructured":"Gehrke, J., Korn, F., Srivastava, D.: On computing correlated aggregates over continual data streams. ACM SIGMOD Record 30(2), 13\u201324 (2001)","journal-title":"ACM SIGMOD Record"},{"key":"778_CR43","first-page":"191","volume":"212","author":"C Giannella","year":"2003","unstructured":"Giannella, C., Han, J., Pei, J., Yan, X., Yu, P.S.: Mining frequent patterns in data streams at multiple time granularities. Next Gener. Data Min. 212, 191\u2013212 (2003)","journal-title":"Next Gener. Data Min."},{"key":"778_CR44","doi-asserted-by":"crossref","unstructured":"Giouroukis, D., Dadiani, A., Traub, J., Zeuch, S., Markl, V.: A survey of adaptive sampling and filtering algorithms for the internet of things. In: DEBS, pp. 27\u201338 (2020)","DOI":"10.1145\/3401025.3403777"},{"issue":"2","key":"778_CR45","doi-asserted-by":"publisher","first-page":"5","DOI":"10.1145\/776985.776986","volume":"32","author":"L Golab","year":"2003","unstructured":"Golab, L., \u00d6zsu, M.T.: Issues in data stream management. SIGMOD Rec. 32(2), 5\u201314 (2003)","journal-title":"SIGMOD Rec."},{"key":"778_CR46","unstructured":"Google Cloud Dataflow. https:\/\/cloud.google.com\/dataflow. Accessed 20 Oct 2021"},{"key":"778_CR47","unstructured":"Google Cloud Dataflow Documentation. Triggers. https:\/\/cloud.google.com\/dataflow\/docs\/concepts\/streaming-pipelines#triggers. Accessed 21 Oct 2021"},{"key":"778_CR48","unstructured":"Google Cloud Dataflow Documentation. Streaming pipelines. https:\/\/cloud.google.com\/dataflow\/docs\/concepts\/streaming-pipelines. Accessed 20 Oct 2021"},{"key":"778_CR49","unstructured":"Grabs, T., Schindlauer, R., Krishnan, R., Goldstein, J., Fern\u00e1ndez, R.: Introducing microsoft streaminsight. Technical report (2009)"},{"key":"778_CR50","doi-asserted-by":"crossref","unstructured":"Grossniklaus, M., Maier, D., Miller, J., Moorthy, S., Tufte, K.: Frames: data-driven windows. In: DEBS, pp. 13\u201324. ACM (2016)","DOI":"10.1145\/2933267.2933304"},{"key":"778_CR51","doi-asserted-by":"crossref","unstructured":"Grulich, P.M., Sebastian, B., Zeuch, S., Traub, J., Bleichert, J.v., Chen, Z., Rabl, T., Markl, V.: Grizzly: efficient stream processing through adaptive query compilation. In: SIGMOD, pp. 2487\u20132503 (2020)","DOI":"10.1145\/3318464.3389739"},{"key":"778_CR52","doi-asserted-by":"crossref","unstructured":"Grulich, P.M., et\u00a0al.: Babelfish: efficient execution of polyglot queries. In: VLDB. VLDB endowment (2021)","DOI":"10.14778\/3489496.3489501"},{"key":"778_CR53","doi-asserted-by":"crossref","unstructured":"Guha, S., Koudas, N.: Approximating a data stream for querying and estimation: algorithms and performance evaluation. In: ICDE, pp. 567\u2013576. IEEE (2002)","DOI":"10.1109\/ICDE.2002.994775"},{"issue":"12","key":"778_CR54","first-page":"2351","volume":"23","author":"V Gulisano","year":"2012","unstructured":"Gulisano, V., Jimenez-Peris, R., Patino-Martinez, M., Soriente, C., Valduriez, P.: Streamcloud: an elastic and scalable data streaming system. IEEE TPDS 23(12), 2351\u20132365 (2012)","journal-title":"IEEE TPDS"},{"issue":"2","key":"778_CR55","doi-asserted-by":"publisher","first-page":"1","DOI":"10.1145\/3131272","volume":"4","author":"V Gulisano","year":"2017","unstructured":"Gulisano, V., Nikolakopoulos, Y., Cederman, D., Papatriantafilou, M., Tsigas, P.: Efficient data streaming multiway aggregation through concurrent algorithmic designs and new abstract data types. ACM TOPC 4(2), 1\u201328 (2017)","journal-title":"ACM TOPC"},{"key":"778_CR56","unstructured":"Hirzel, M., Andrade, H., Gedik, B., Kumar, V., Losa, G., Nasgaard, H., Soule, R., Wu, K.L.: Spl stream processing language specification. Technical report IBM (2009)"},{"key":"778_CR57","doi-asserted-by":"crossref","unstructured":"Hirzel, M., Schneider, S., Tangwongsan, K.: Tutorial: sliding-window aggregation algorithms. In: DEBS, pp. 11\u201314 (2017)","DOI":"10.1145\/3093742.3095107"},{"key":"778_CR58","doi-asserted-by":"publisher","DOI":"10.1145\/2528412","author":"M Hirzel","year":"2014","unstructured":"Hirzel, M., Soul\u00e9, R., Schneider, S., Gedik, B., Grimm, R.: A catalog of stream processing optimizations. ACM CSUR (2014). https:\/\/doi.org\/10.1145\/2528412","journal-title":"ACM CSUR"},{"key":"778_CR59","unstructured":"IBM Streams Documentation. https:\/\/www.ibm.com\/docs\/en\/streams\/5.5?topic=welcome-introduction-streams. Accessed 19 Oct 2021"},{"key":"778_CR60","unstructured":"IBM Streams Documentation. Window clause. https:\/\/www.ibm.com\/docs\/en\/streams\/5.5?topic=invocations-window-clause. Accessed 19 Oct 2021"},{"key":"778_CR61","doi-asserted-by":"crossref","unstructured":"Karimov, J., Rabl, T., Markl, V.: Astream: Ad-hoc shared stream processing. In: SIGMOD, pp. 607\u2013622 (2019)","DOI":"10.1145\/3299869.3319884"},{"key":"778_CR62","doi-asserted-by":"crossref","unstructured":"Koliousis, A., Weidlich, M., Castro\u00a0Fernandez, R., Wolf, A.L., Costa, P., Pietzuch, P.: Saber: window-based hybrid stream processing for heterogeneous architectures. In: SIGMOD, pp. 555\u2013569 (2016)","DOI":"10.1145\/2882903.2882906"},{"key":"778_CR63","doi-asserted-by":"crossref","unstructured":"Krishnamurthy, S., Wu, C., Franklin, M.J.: On-the-fly sharing for streamed aggregation. In: SIGMOD, pp. 623\u2013634 (2006)","DOI":"10.1145\/1142473.1142543"},{"key":"778_CR64","doi-asserted-by":"crossref","unstructured":"Kulkarni, S., Bhagat, N., Fu, M., Kedigehalli, V., Kellogg, C., Mittal, S., Patel, J.M., Ramasamy, K., Taneja, S.: Twitter heron: stream processing at scale. In: Proceedings of the 2015 ACM SIGMOD International Conference on Management of Data, pp. 239\u2013250 (2015)","DOI":"10.1145\/2723372.2742788"},{"key":"778_CR65","doi-asserted-by":"crossref","unstructured":"Lal, D.K., Suman, U.: A survey of real-time big data processing algorithms. In: Reliability and Risk Assessment in Engineering, pp. 3\u201310. Springer, Berlin (2020)","DOI":"10.1007\/978-981-15-3746-2_1"},{"issue":"1","key":"778_CR66","doi-asserted-by":"publisher","first-page":"39","DOI":"10.1145\/1058150.1058158","volume":"34","author":"J Li","year":"2005","unstructured":"Li, J., Maier, D., Tufte, K., Papadimos, V., Tucker, P.A.: No pane, no gain: efficient evaluation of sliding-window aggregates over data streams. SIGMOD Record 34(1), 39\u201344 (2005)","journal-title":"SIGMOD Record"},{"key":"778_CR67","doi-asserted-by":"crossref","unstructured":"Li, J., Maier, D., Tufte, K., Papadimos, V., Tucker, P.A.: Semantics and evaluation techniques for window aggregates in data streams. In: SIGMOD, pp. 311\u2013322 (2005)","DOI":"10.1145\/1066157.1066193"},{"issue":"6","key":"778_CR68","doi-asserted-by":"publisher","first-page":"22","DOI":"10.1109\/MIC.2008.116","volume":"12","author":"J Li","year":"2008","unstructured":"Li, J., Tufte, K., Maier, D., Papadimos, V.: Adaptwid: an adaptive, memory-efficient window aggregation implementation. IEEE Internet Comput. 12(6), 22\u201329 (2008)","journal-title":"IEEE Internet Comput."},{"issue":"1","key":"778_CR69","first-page":"274","volume":"1","author":"J Li","year":"2008","unstructured":"Li, J., Tufte, K., Shkapenyuk, V., Papadimos, V., Johnson, T., Maier, D.: Out-of-order processing: a new architecture for high-performance stream systems. PVLDB 1(1), 274\u2013288 (2008)","journal-title":"PVLDB"},{"key":"778_CR70","doi-asserted-by":"publisher","first-page":"167","DOI":"10.1002\/sam.11380","volume":"11","author":"S Mansalis","year":"2018","unstructured":"Mansalis, S., Ntoutsi, E., Pelekis, N., Theodoridis, Y.: An evaluation of data stream clustering algorithms. Stat. Anal. Data Min.: ASA Data Sci. J. 11, 167\u2013187 (2018)","journal-title":"Stat. Anal. Data Min.: ASA Data Sci. J."},{"key":"778_CR71","unstructured":"Microsoft Azure Stream Analytics Documentation. Introduction to Stream Analytics windowing functions. https:\/\/docs.microsoft.com\/en-us\/azure\/stream-analytics\/stream-analytics-window-functions. Accessed 02 Feb 2020"},{"key":"778_CR72","unstructured":"Microsoft Blog. Windows in StreamInsight: Hopping vs. Snapshot. https:\/\/blogs.msdn.microsoft.com\/streaminsight\/2010\/12\/15\/windows-in-streaminsight-hopping-vs-snapshot\/. Accessed 02 Feb 2020"},{"key":"778_CR73","unstructured":"Microsoft StreamInsight Developer\u2019s Guide. Using Event Windows. https:\/\/docs.microsoft.com\/en-us\/previous-versions\/sql\/streaminsight\/ee842704(v=sql.111). Accessed 18 Oct 2021"},{"key":"778_CR74","doi-asserted-by":"crossref","unstructured":"Murray, D.G., McSherry, F., Isaacs, R., Isard, M., Barham, P., Abadi, M.: Naiad: a timely dataflow system. In: SOSP ACM, pp. 439\u2013455 (2013)","DOI":"10.1145\/2517349.2522738"},{"issue":"12","key":"778_CR75","first-page":"1634","volume":"10","author":"SA Noghabi","year":"2017","unstructured":"Noghabi, S.A., Paramasivam, K., Pan, Y., Ramesh, N., Bringhurst, J., Gupta, I., Campbell, R.H.: Samza: stateful scalable stream processing at linkedin. PVLDB 10(12), 1634\u20131645 (2017)","journal-title":"PVLDB"},{"key":"778_CR76","doi-asserted-by":"crossref","unstructured":"Patroumpas, K., Sellis, T.: Window specification over data streams. In: EDBT, pp. 445\u2013464 (2006)","DOI":"10.1007\/11896548_35"},{"issue":"10","key":"778_CR77","doi-asserted-by":"publisher","first-page":"1818","DOI":"10.14778\/3467861.3467871","volume":"14","author":"R Poepsel-Lemaitre","year":"2021","unstructured":"Poepsel-Lemaitre, R., Kiefer, M., von Hein, J., Quian\u00e9-Ruiz, J.A., Markl, V.: In the land of data streams where synopses are missing, one framework to bring them all. VLDB Endowment 14(10), 1818\u20131831 (2021)","journal-title":"VLDB Endowment"},{"key":"778_CR78","doi-asserted-by":"crossref","unstructured":"Quoc, D.L., Chen, R., Bhatotia, P., Fetzer, C., Hilt, V., Strufe, T.: Streamapprox: approximate computing for stream analytics. In: ACM\/IFIP\/USENIX Middleware, pp. 185\u2013197 (2017)","DOI":"10.1145\/3135974.3135989"},{"key":"778_CR79","doi-asserted-by":"crossref","unstructured":"Schneider, S., Hirzel, M., Gedik, B.: Tutorial: stream processing optimizations. In: DEBS, pp. 249\u2013258 (2013)","DOI":"10.1145\/2488222.2488268"},{"key":"778_CR80","doi-asserted-by":"crossref","unstructured":"Shein, A.U., Chrysanthis, P.K., Labrinidis, A.: Flatfit: accelerated incremental sliding-window aggregation for real-time analytics. In: SSDBM, pp. 1\u201312 (2017)","DOI":"10.1145\/3085504.3085509"},{"key":"778_CR81","unstructured":"Shein, A.U., Chrysanthis, P.K., Labrinidis, A.: Slickdeque: High throughput and low latency incremental sliding-window aggregation. In: EDBT, pp. 397\u2013408 (2018)"},{"key":"778_CR82","doi-asserted-by":"crossref","unstructured":"Tangwongsan, K., Hirzel, M., Schneider, S.: Low-latency sliding-window aggregation in worst-case constant time. In: DEBS, pp. 66\u201377 (2017)","DOI":"10.1145\/3093742.3093925"},{"issue":"10","key":"778_CR83","first-page":"1167","volume":"12","author":"K Tangwongsan","year":"2019","unstructured":"Tangwongsan, K., Hirzel, M., Schneider, S.: Optimal and general out-of-order sliding-window aggregation. PVLDB 12(10), 1167\u20131180 (2019)","journal-title":"PVLDB"},{"issue":"7","key":"778_CR84","first-page":"702","volume":"8","author":"K Tangwongsan","year":"2015","unstructured":"Tangwongsan, K., Hirzel, M., Schneider, S., Wu, K.L.: General incremental sliding-window aggregation. PVLDB 8(7), 702\u2013713 (2015)","journal-title":"PVLDB"},{"key":"778_CR85","doi-asserted-by":"crossref","unstructured":"Tatbul, N., \u00c7etintemel, U., Zdonik, S., Cherniack, M., Stonebraker, M.: Load shedding in a data stream manager. In: Proceedings 2003 VLDB conference, pp. 309\u2013320. Elsevier, Amsterdam (2003)","DOI":"10.1016\/B978-012722442-8\/50035-5"},{"key":"778_CR86","unstructured":"Theodorakis, G., Koliousis, A., Pietzuch, P., Holger, P.: Hammer slide: work-and CPU-efficient streaming window aggregation (2018)"},{"key":"778_CR87","doi-asserted-by":"crossref","unstructured":"Theodorakis, G., Koliousis, A., Pietzuch, P., Pirk, H.: Lightsaber: efficient window aggregation on multi-core processors. In: SIGMOD, pp. 2505\u20132521 (2020)","DOI":"10.1145\/3318464.3389753"},{"key":"778_CR88","unstructured":"Theodorakis, G., Pietzuch, P.R., Pirk, H.: Slideside: a fast incremental stream processing algorithm for multiple queries. In: EDBT, pp. 435\u2013438 (2020)"},{"key":"778_CR89","doi-asserted-by":"crossref","unstructured":"Torres, J., Armbrust, M., Das, T., Zhu, S.: Introducing low-latency continuous processing mode in structured streaming in apache spark 2.3. Databricks Blog (2018)","DOI":"10.1145\/3183713.3190664"},{"key":"778_CR90","doi-asserted-by":"crossref","unstructured":"Toshniwal, A., Taneja, S., Shukla, A., Ramasamy, K., Patel, J.M., Kulkarni, S., Jackson, J., Gade, K., Fu, M., Donham, J., et\u00a0al.: Storm@ twitter. In: SIGMOD, pp. 147\u2013156 (2014)","DOI":"10.1145\/2588555.2595641"},{"key":"778_CR91","unstructured":"Traub, J.: Demand-based data stream gathering, processing, and transmission. Ph.D. thesis, Technische Universit\u00e4t Berlin (2019). https:\/\/www.depositonce.tu-berlin.de\/handle\/11303\/10519"},{"key":"778_CR92","doi-asserted-by":"crossref","unstructured":"Traub, J., Grulich, P., Cu\u00e9llar, A.R., Bre\u00df, S., Katsifodimos, A., Rabl, T., Markl, V.: Scotty: efficient window aggregation for out-of-order stream processing. In: IEEE ICDE, pp. 1300\u20131303 (2018)","DOI":"10.1109\/ICDE.2018.00135"},{"key":"778_CR93","unstructured":"Traub, J., Grulich, P., Cu\u00e9llar, A.R., Bre\u00df, S., Katsifodimos, A., Rabl, T., Markl, V.: Efficient window aggregation with general stream slicing. In: EDBT, pp. 97\u2013108 (2019)"},{"key":"778_CR94","doi-asserted-by":"crossref","unstructured":"Traub, J., Grulich, P.M., Cu\u00e9llar, A.R., Bre\u00df, S., Katsifodimos, A., Rabl, T., Markl, V.: Scotty: general and efficient open-source window aggregation for stream processing systems. ACM TODS 46(1), 1\u201346 (2021)","DOI":"10.1145\/3433675"},{"issue":"3","key":"778_CR95","first-page":"555","volume":"15","author":"PA Tucker","year":"2003","unstructured":"Tucker, P.A., Maier, D., Sheard, T., Fegaras, L.: Exploiting punctuation semantics in continuous data streams. IEEE TKDE 15(3), 555\u2013568 (2003)","journal-title":"IEEE TKDE"},{"issue":"11","key":"778_CR96","doi-asserted-by":"publisher","first-page":"56","DOI":"10.1145\/2934664","volume":"59","author":"M Zaharia","year":"2016","unstructured":"Zaharia, M., Xin, R.S., Wendell, P., Das, T., Armbrust, M., Dave, A., Meng, X., Rosen, J., Venkataraman, S., Franklin, M.J., et al.: Apache spark: a unified engine for big data processing. CACM 59(11), 56\u201365 (2016)","journal-title":"CACM"},{"key":"778_CR97","unstructured":"Zeuch, S., Chaudhary, A., Monte, B., Gavriilidis, H., Giouroukis, D., Grulich, P., Bre\u00df, S., Traub, J., Markl, V.: The NebulaStream Platform: data and application management for the internet of things. In: CIDR (2020)"},{"issue":"5","key":"778_CR98","first-page":"516","volume":"12","author":"S Zeuch","year":"2019","unstructured":"Zeuch, S., Monte, B.D., Karimov, J., Lutz, C., Renz, M., Traub, J., Bre\u00df, S., Rabl, T., Markl, V.: Analyzing efficient stream processing on modern hardware. PVLDB 12(5), 516\u2013530 (2019)","journal-title":"PVLDB"},{"key":"778_CR99","unstructured":"Zeuch, S., Zacharatou, E.T., Zhang, S., Chatziliadis, X., Chaudhary, A., Del\u00a0Monte, B., Giouroukis, D., Grulich, P.M., Ziehn, A., Mark, V.: NebulaStream: complex analytics beyond the cloud. In: VLIoT (2020)"},{"key":"778_CR100","doi-asserted-by":"crossref","unstructured":"Zhang, C., Akbarinia, R., Toumani, F.: Efficient incremental computation of aggregations over sliding windows. In: ACM SIGKDD, pp. 2136\u20132144 (2021)","DOI":"10.1145\/3447548.3467360"}],"updated-by":[{"DOI":"10.1007\/s00778-023-00793-1","type":"correction","label":"Correction","source":"publisher","updated":{"date-parts":[[2023,5,17]],"date-time":"2023-05-17T00:00:00Z","timestamp":1684281600000}}],"container-title":["The VLDB Journal"],"original-title":[],"language":"en","link":[{"URL":"https:\/\/link.springer.com\/content\/pdf\/10.1007\/s00778-022-00778-6.pdf","content-type":"application\/pdf","content-version":"vor","intended-application":"text-mining"},{"URL":"https:\/\/link.springer.com\/article\/10.1007\/s00778-022-00778-6\/fulltext.html","content-type":"text\/html","content-version":"vor","intended-application":"text-mining"},{"URL":"https:\/\/link.springer.com\/content\/pdf\/10.1007\/s00778-022-00778-6.pdf","content-type":"application\/pdf","content-version":"vor","intended-application":"similarity-checking"}],"deposited":{"date-parts":[[2024,10,14]],"date-time":"2024-10-14T15:19:20Z","timestamp":1728919160000},"score":1,"resource":{"primary":{"URL":"https:\/\/link.springer.com\/10.1007\/s00778-022-00778-6"}},"subtitle":[],"short-title":[],"issued":{"date-parts":[[2023,2,17]]},"references-count":100,"journal-issue":{"issue":"5","published-print":{"date-parts":[[2023,9]]}},"alternative-id":["778"],"URL":"https:\/\/doi.org\/10.1007\/s00778-022-00778-6","relation":{"correction":[{"id-type":"doi","id":"10.1007\/s00778-023-00793-1","asserted-by":"object"}]},"ISSN":["1066-8888","0949-877X"],"issn-type":[{"value":"1066-8888","type":"print"},{"value":"0949-877X","type":"electronic"}],"subject":[],"published":{"date-parts":[[2023,2,17]]},"assertion":[{"value":"13 March 2022","order":1,"name":"received","label":"Received","group":{"name":"ArticleHistory","label":"Article History"}},{"value":"12 December 2022","order":2,"name":"revised","label":"Revised","group":{"name":"ArticleHistory","label":"Article History"}},{"value":"29 December 2022","order":3,"name":"accepted","label":"Accepted","group":{"name":"ArticleHistory","label":"Article History"}},{"value":"17 February 2023","order":4,"name":"first_online","label":"First Online","group":{"name":"ArticleHistory","label":"Article History"}},{"value":"17 May 2023","order":5,"name":"change_date","label":"Change Date","group":{"name":"ArticleHistory","label":"Article History"}},{"value":"Correction","order":6,"name":"change_type","label":"Change Type","group":{"name":"ArticleHistory","label":"Article History"}},{"value":"A Correction to this paper has been published:","order":7,"name":"change_details","label":"Change Details","group":{"name":"ArticleHistory","label":"Article History"}},{"value":"https:\/\/doi.org\/10.1007\/s00778-023-00793-1","URL":"https:\/\/doi.org\/10.1007\/s00778-023-00793-1","order":8,"name":"change_details","label":"Change Details","group":{"name":"ArticleHistory","label":"Article History"}}]}}