{"status":"ok","message-type":"work","message-version":"1.0.0","message":{"indexed":{"date-parts":[[2026,10,1]],"date-time":"2026-10-01T03:55:24Z","timestamp":1790826924914,"version":"4.1.0"},"reference-count":41,"publisher":"Springer Science and Business Media LLC","issue":"5","license":[{"start":{"date-parts":[[2026,8,27]],"date-time":"2026-08-27T00:00:00Z","timestamp":1787788800000},"content-version":"tdm","delay-in-days":0,"URL":"https:\/\/www.springernature.com\/gp\/researchers\/text-and-data-mining"},{"start":{"date-parts":[[2026,8,27]],"date-time":"2026-08-27T00:00:00Z","timestamp":1787788800000},"content-version":"vor","delay-in-days":0,"URL":"https:\/\/www.springernature.com\/gp\/researchers\/text-and-data-mining"}],"content-domain":{"domain":["link.springer.com"],"crossmark-restriction":false},"short-container-title":["Data Min Knowl Disc"],"published-print":{"date-parts":[[2026,9]]},"DOI":"10.1007\/s10618-026-01252-5","type":"journal-article","created":{"date-parts":[[2026,8,27]],"date-time":"2026-08-27T06:29:29Z","timestamp":1787812169000},"update-policy":"https:\/\/doi.org\/10.1007\/springer_crossmark_policy","source":"Crossref","is-referenced-by-count":0,"title":["Parallelization of incremental aggregations over sliding windows"],"prefix":"10.1007","volume":"40","author":[{"ORCID":"https:\/\/orcid.org\/0000-0003-4972-9380","authenticated-orcid":false,"given":"Chao","family":"Zhang","sequence":"first","affiliation":[],"role":[{"vocabulary":"crossref","role":"author"}]},{"given":"Reza","family":"Akbarinia","sequence":"additional","affiliation":[],"role":[{"vocabulary":"crossref","role":"author"}]},{"given":"Farouk","family":"Toumani","sequence":"additional","affiliation":[],"role":[{"vocabulary":"crossref","role":"author"}]}],"member":"297","published-online":{"date-parts":[[2026,8,27]]},"reference":[{"key":"1252_CR1","doi-asserted-by":"crossref","unstructured":"Akidau T, Balikov A, Bekiro\u011flu K, Chernyak S, Haberman J, Lax R, McVeety S, Mills D, Nordstrom P, Whittle S (2013) Millwheel: Fault-tolerant stream processing at internet scale. Proc, VLDB Endow","DOI":"10.14778\/2536222.2536229"},{"key":"1252_CR2","doi-asserted-by":"crossref","unstructured":"Arasu A, Widom J (2004) Resource sharing in continuous sliding-window aggregates. VLDB,","DOI":"10.1016\/B978-012088469-8.50032-2"},{"key":"1252_CR3","unstructured":"Benson L, Rabl T (2022) Darwin: scale-in stream processing. In: 12th Conference on Innovative Data Systems Research, CIDR 2022, Chaminade, CA, USA, January 9-12, 2022. www.cidrdb.org, ???. https:\/\/www.cidrdb.org\/cidr2022\/papers\/p34-benson.pdf"},{"issue":"8","key":"1252_CR4","doi-asserted-by":"publisher","first-page":"3107","DOI":"10.1007\/s10115-020-01444-5","volume":"62","author":"S Bou","year":"2020","unstructured":"Bou S, Kitagawa H, Amagasa T (2020) L-bix: Incremental sliding-window aggregation over data streams using linear bidirectional aggregating indexes. Knowl Inf Syst 62(8):3107\u20133131. https:\/\/doi.org\/10.1007\/s10115-020-01444-5","journal-title":"Knowl Inf Syst"},{"key":"1252_CR5","unstructured":"Carbone P, Katsifodimos A, Ewen S, Markl V, Haridi S, Tzoumas K (2015) Apache flink: Stream and batch processing in a single engine. IEEE Data Eng, Bull"},{"key":"1252_CR6","doi-asserted-by":"crossref","unstructured":"Carbone P, Traub J, Katsifodimos A, Haridi S, Markl V (2016) Cutty: aggregate sharing for user-defined windows. CIKM \u201916","DOI":"10.1145\/2983323.2983807"},{"key":"1252_CR7","doi-asserted-by":"crossref","unstructured":"Cugola G, Margara A (2012) Processing flows of information: from data stream to complex event processing. ACM Comput, Surv","DOI":"10.1145\/2187671.2187677"},{"key":"1252_CR8","doi-asserted-by":"crossref","unstructured":"Koliousis A, Weidlich M, Castro Fernandez R, Wolf AL, Costa P, Pietzuch P (2016) Saber: window-based hybrid stream processing for heterogeneous architectures. p SIGMOD","DOI":"10.1145\/2882903.2882906"},{"key":"1252_CR9","doi-asserted-by":"crossref","unstructured":"Gan E, Ding J, Tai KS, Sharan V, Bailis P (2018) Moment-based quantile sketches for efficient high cardinality aggregation queries. Proc, VLDB Endow","DOI":"10.14778\/3236187.3236212"},{"key":"1252_CR10","doi-asserted-by":"crossref","unstructured":"Gray J, Chaudhuri S, Bosworth A, Layman A, Reichart D, Venkatrao M, Pellow F, Pirahesh H (1997) Data cube: A relational aggregation operator generalizing group-by, cross-tab, and sub-totals. Data Min. Knowl, Discov","DOI":"10.1023\/A:1009726021843"},{"key":"1252_CR11","doi-asserted-by":"publisher","unstructured":"Grulich PM, Bre\u00df S, Zeuch S, Traub J, Bleichert J, Chen Z, Rabl T, Markl V (2020) Grizzly: efficient stream processing through adaptive query compilation. In: Maier, D., Pottinger, R., Doan, A., Tan, W., Alawini, A., Ngo, H.Q. (eds.) Proceedings of the 2020 International Conference on Management of Data, SIGMOD Conference 2020, Online Conference [Portland, OR, USA], June 14-19, 2020, pp. 2487\u20132503. ACM, ???. https:\/\/doi.org\/10.1145\/3318464.3389739","DOI":"10.1145\/3318464.3389739"},{"key":"1252_CR12","doi-asserted-by":"crossref","unstructured":"Gupta V, Hewett R (2020) Real-time tweet analytics using hybrid hashtags on twitter big data streams. Inf","DOI":"10.3390\/info11070341"},{"key":"1252_CR13","doi-asserted-by":"crossref","unstructured":"Heinze T, Aniello L, Querzoni L, Jerzak Z (2014) Cloud-based data stream processing. DEBS,","DOI":"10.1145\/2611286.2611309"},{"key":"1252_CR14","doi-asserted-by":"crossref","unstructured":"Hirzel M, Schneider S, Tangwongsan K (2017) Sliding-window aggregation algorithms: Tutorial. p DEBS","DOI":"10.1145\/3093742.3095107"},{"key":"1252_CR15","doi-asserted-by":"crossref","unstructured":"Hirzel M, Soul\u00e9 R, Schneider S, Gedik B, Grimm R (2014) A catalog of stream processing optimizations. ACM Comput, Surv","DOI":"10.1145\/2528412"},{"key":"1252_CR16","unstructured":"https:\/\/flink.apache.org (2019)"},{"key":"1252_CR17","unstructured":"https:\/\/github.com\/chaozhang-db\/PBA (2021)"},{"key":"1252_CR18","unstructured":"https:\/\/github.com\/dataArtisans\/flink-benchmarks (2019)"},{"key":"1252_CR19","unstructured":"https:\/\/spark.apache.org\/ (2019)"},{"key":"1252_CR20","doi-asserted-by":"publisher","unstructured":"Jayarajan A, Zhao W, Sun Y, Pekhimenko G (2023) Tilt: a time-centric approach for stream query optimization and parallelization. In: Aamodt TM, Jerger NDE, Swift MM (eds.) Proceedings of the 28th ACM International Conference on Architectural Support for Programming Languages and Operating Systems, Volume 2, ASPLOS 2023, Vancouver, BC, Canada, March 25-29, 2023, pp. 818\u2013832. ACM, ???. https:\/\/doi.org\/10.1145\/3575693.3575704","DOI":"10.1145\/3575693.3575704"},{"key":"1252_CR21","doi-asserted-by":"crossref","unstructured":"Jerzak Z, Heinze T, Fehr M, Gr\u00f6ber D, Hartung R, Stojanovic N (2012) The debs 2012 grand challenge. DEBS,","DOI":"10.1145\/2335484.2335536"},{"key":"1252_CR22","doi-asserted-by":"crossref","unstructured":"Jerzak Z, Ziekow H (2014) The debs 2014 grand challenge. DEBS,","DOI":"10.1145\/2611286.2611333"},{"key":"1252_CR23","doi-asserted-by":"crossref","unstructured":"Krishnamurthy S, Wu C, Franklin M (2006) On-the-fly sharing for streamed aggregation. p SIGMOD","DOI":"10.1145\/1142473.1142543"},{"key":"1252_CR24","doi-asserted-by":"crossref","unstructured":"Kulkarni S, Bhagat N, Fu M, Kedigehalli V, Kellogg C, Mittal S, Patel JM, Ramasamy K, Taneja S (2015) Twitter heron: Stream processing at scale. p SIGMOD","DOI":"10.1145\/2723372.2742788"},{"key":"1252_CR25","doi-asserted-by":"crossref","unstructured":"Li J, Maier D, Tufte K, Papadimos V, Tucker PA (2005) No pane, no gain: Efficient evaluation of sliding-window aggregates over data streams. SIGMOD Rec","DOI":"10.1145\/1058150.1058158"},{"key":"1252_CR26","doi-asserted-by":"crossref","unstructured":"Li J, Maier D, Tufte K, Papadimos V, Tucker PA (2005) Semantics and evaluation techniques for window aggregates in data streams. p SIGMOD","DOI":"10.1145\/1066157.1066193"},{"key":"1252_CR27","doi-asserted-by":"crossref","unstructured":"Li J, Tufte K, Shkapenyuk V, Papadimos V, Johnson T, Maier D (2008) Out-of-order processing: A new architecture for high-performance stream systems. Proc, VLDB Endow","DOI":"10.14778\/1453856.1453890"},{"key":"1252_CR28","doi-asserted-by":"crossref","unstructured":"R\u00f6ger H, Mayer R (2019) A comprehensive survey on parallelization and elasticity in stream processing. ACM Comput, Surv","DOI":"10.1145\/3303849"},{"key":"1252_CR29","doi-asserted-by":"crossref","unstructured":"Shein AU, Chrysanthis PK, Labrinidis A (2017) Flatfit: accelerated incremental sliding-window aggregation for real-time analytics. p SSDBM","DOI":"10.1145\/3085504.3085509"},{"key":"1252_CR30","unstructured":"Shein AU, Chrysanthis PK, Labrinidis A (2018) Slickdeque: high throughput and low latency incremental sliding-window aggregation. EDBT,"},{"key":"1252_CR31","doi-asserted-by":"publisher","first-page":"933","DOI":"10.1007\/s00778-021-00668-3","volume":"30","author":"K Tangwongsan","year":"2021","unstructured":"Tangwongsan K, Hirzel M, Schneider S (2021) In-order sliding-window aggregation in worst-case constant time. VLDB J 30:933\u2013957","journal-title":"VLDB J"},{"key":"1252_CR32","doi-asserted-by":"crossref","unstructured":"Tangwongsan K, Hirzel M, Schneider S (2017) Low-latency sliding-window aggregation in worst-case constant time. p DEBS","DOI":"10.1145\/3093742.3093925"},{"key":"1252_CR33","doi-asserted-by":"crossref","unstructured":"Tangwongsan K, Hirzel M, Schneider S, Wu K-L (2015) General incremental sliding-window aggregation. PVLDB","DOI":"10.14778\/2752939.2752940"},{"key":"1252_CR34","doi-asserted-by":"publisher","unstructured":"Theodorakis G, Koliousis A, Pietzuch PR, Pirk H (2020) Lightsaber: efficient window aggregation on multi-core processors. In: Maier D, Pottinger R, Doan A, Tan W, Alawini A, Ngo HQ (eds.) Proceedings of the 2020 International Conference on Management of Data, SIGMOD Conference 2020, Online Conference [Portland, OR, USA], June 14-19, 2020, pp. 2505\u20132521. ACM, ???. https:\/\/doi.org\/10.1145\/3318464.3389753","DOI":"10.1145\/3318464.3389753"},{"key":"1252_CR35","unstructured":"Theodorakis G, Pietzuch P, Pirk H (2020) Slideside: a fast incremental stream processing algorithm for multiple queries. EDBT,"},{"key":"1252_CR36","doi-asserted-by":"crossref","unstructured":"Toshniwal A, Taneja S, Shukla A, Ramasamy K, Patel JM, Kulkarni S, Jackson J, Gade K, Fu M, Donham J, Bhagat N, Mittal S, Ryaboy D (2014) Storm@twitter. p SIGMOD","DOI":"10.1145\/2588555.2595641"},{"key":"1252_CR37","unstructured":"Traub J, Grulich PM, Cuellar AR, Bre\u00df S, Katsifodimos A, Rabl T, Markl V (2019) Efficient window aggregation with general stream slicing. EDBT,"},{"key":"1252_CR38","doi-asserted-by":"crossref","unstructured":"Zaharia M, Das T, Li H, Hunter T, Shenker S, Stoica I (2013) Discretized streams: Fault-tolerant streaming computation at scale. p SOSP","DOI":"10.1145\/2517349.2522737"},{"key":"1252_CR39","doi-asserted-by":"crossref","unstructured":"Zeuch S, Monte BD, Karimov J, Lutz C, Renz M, Traub J, Bre\u00df S, Rabl T, Markl V (2019) Analyzing efficient stream processing on modern hardware. Proc, VLDB Endow","DOI":"10.14778\/3303753.3303758"},{"key":"1252_CR40","doi-asserted-by":"publisher","unstructured":"Zhang C, Akbarinia R, Toumani F (2021) Efficient incremental computation of aggregations over sliding windows. In: Proceedings of the 27th ACM SIGKDD Conference on Knowledge Discovery & Data Mining (KDD), pp. 2136\u20132144. https:\/\/doi.org\/10.1145\/3447548.3467360","DOI":"10.1145\/3447548.3467360"},{"key":"1252_CR41","doi-asserted-by":"crossref","unstructured":"Zhang S, He B, Dahlmeier D, Zhou AC Heinze T (2017) Revisiting the design of data stream processing systems on multi-core processors. In: ICDE","DOI":"10.1109\/ICDE.2017.119"}],"container-title":["Data Mining and Knowledge Discovery"],"original-title":[],"language":"en","link":[{"URL":"https:\/\/link.springer.com\/content\/pdf\/10.1007\/s10618-026-01252-5.pdf","content-type":"application\/pdf","content-version":"vor","intended-application":"text-mining"},{"URL":"https:\/\/link.springer.com\/article\/10.1007\/s10618-026-01252-5","content-type":"text\/html","content-version":"vor","intended-application":"text-mining"},{"URL":"https:\/\/link.springer.com\/content\/pdf\/10.1007\/s10618-026-01252-5.pdf","content-type":"application\/pdf","content-version":"vor","intended-application":"similarity-checking"}],"deposited":{"date-parts":[[2026,10,1]],"date-time":"2026-10-01T03:06:05Z","timestamp":1790823965000},"score":1,"resource":{"primary":{"URL":"https:\/\/link.springer.com\/10.1007\/s10618-026-01252-5"}},"subtitle":[],"short-title":[],"issued":{"date-parts":[[2026,8,27]]},"references-count":41,"journal-issue":{"issue":"5","published-print":{"date-parts":[[2026,9]]}},"alternative-id":["1252"],"URL":"https:\/\/doi.org\/10.1007\/s10618-026-01252-5","relation":{},"ISSN":["1384-5810","1573-756X"],"issn-type":[{"value":"1384-5810","type":"print"},{"value":"1573-756X","type":"electronic"}],"subject":[],"published":{"date-parts":[[2026,8,27]]},"assertion":[{"value":"11 August 2023","order":1,"name":"received","label":"Received","group":{"name":"ArticleHistory","label":"Article History"}},{"value":"5 August 2026","order":2,"name":"accepted","label":"Accepted","group":{"name":"ArticleHistory","label":"Article History"}},{"value":"27 August 2026","order":3,"name":"first_online","label":"First Online","group":{"name":"ArticleHistory","label":"Article History"}}],"article-number":"83"}}