{"status":"ok","message-type":"work","message-version":"1.0.0","message":{"indexed":{"date-parts":[[2026,3,30]],"date-time":"2026-03-30T18:01:24Z","timestamp":1774893684454,"version":"3.50.1"},"publisher-location":"Singapore","reference-count":20,"publisher":"Springer Nature Singapore","isbn-type":[{"value":"9789819584109","type":"print"},{"value":"9789819584116","type":"electronic"}],"license":[{"start":{"date-parts":[[2026,1,1]],"date-time":"2026-01-01T00:00:00Z","timestamp":1767225600000},"content-version":"tdm","delay-in-days":0,"URL":"https:\/\/www.springernature.com\/gp\/researchers\/text-and-data-mining"},{"start":{"date-parts":[[2026,1,1]],"date-time":"2026-01-01T00:00:00Z","timestamp":1767225600000},"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":[],"published-print":{"date-parts":[[2026]]},"DOI":"10.1007\/978-981-95-8411-6_43","type":"book-chapter","created":{"date-parts":[[2026,3,30]],"date-time":"2026-03-30T17:09:40Z","timestamp":1774890580000},"page":"573-585","update-policy":"https:\/\/doi.org\/10.1007\/springer_crossmark_policy","source":"Crossref","is-referenced-by-count":0,"title":["WindowView: A Stream Processing Engine for\u00a0Big-Data Analytics"],"prefix":"10.1007","author":[{"given":"Bing","family":"Li","sequence":"first","affiliation":[],"role":[{"role":"author","vocabulary":"crossref"}]},{"given":"Wenting","family":"He","sequence":"additional","affiliation":[],"role":[{"role":"author","vocabulary":"crossref"}]},{"given":"Zhibin","family":"Zhang","sequence":"additional","affiliation":[],"role":[{"role":"author","vocabulary":"crossref"}]}],"member":"297","published-online":{"date-parts":[[2026,3,31]]},"reference":[{"key":"43_CR1","doi-asserted-by":"publisher","unstructured":"Akidau, T., et al.: 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"},{"key":"43_CR2","doi-asserted-by":"publisher","unstructured":"Akidau, T., et al.: The dataflow model: a practical approach to balancing correctness, latency, and cost in massive-scale, unbounded, out-of-order data processing. Proc. VLDB Endow. 8(12), 1792\u20131803 (2015). https:\/\/doi.org\/10.14778\/2824032.2824076. http:\/\/dx.doi.org\/10.14778\/2824032.2824076","DOI":"10.14778\/2824032.2824076"},{"key":"43_CR3","doi-asserted-by":"publisher","unstructured":"Ananthanarayanan, R., et al.: Photon: fault-tolerant and scalable joining of continuous data streams. In: Proceedings of the 2013 ACM SIGMOD International Conference on Management of Data, SIGMOD 2013, pp. 577\u2013588. Association for Computing Machinery, New York (2013). https:\/\/doi.org\/10.1145\/2463676.2465272","DOI":"10.1145\/2463676.2465272"},{"key":"43_CR4","doi-asserted-by":"publisher","unstructured":"Armbrust, M., et al.: Structured streaming: a declarative API for real-time applications in apache spark. In: Proceedings of the 2018 International Conference on Management of Data, SIGMOD 2018, pp. 601\u2013613. ACM, New York (2018). https:\/\/doi.org\/10.1145\/3183713.3190664. http:\/\/doi.acm.org\/10.1145\/3183713.3190664","DOI":"10.1145\/3183713.3190664"},{"key":"43_CR5","unstructured":"Axboe: axboe\/fio (2019). https:\/\/github.com\/axboe\/fio"},{"key":"43_CR6","doi-asserted-by":"publisher","unstructured":"Chandramouli, B., et al.: Trill: a high-performance incremental query processor for diverse analytics. Proc. VLDB Endow. 8(4), 401\u2013412 (2014). https:\/\/doi.org\/10.14778\/2735496.2735503. http:\/\/dx.doi.org\/10.14778\/2735496.2735503","DOI":"10.14778\/2735496.2735503"},{"key":"43_CR7","doi-asserted-by":"crossref","unstructured":"Chintapalli, S., et\u00a0al.: Benchmarking streaming computation engines: Storm, flink and spark streaming. In: 2016 IEEE International Parallel and Distributed Processing Symposium Workshops (IPDPSW), pp. 1789\u20131792. IEEE (2016)","DOI":"10.1109\/IPDPSW.2016.138"},{"key":"43_CR8","unstructured":"Chintapalli, S., et al.: Benchmarking streaming computation engines at yahoo! Technical report (2015)"},{"key":"43_CR9","unstructured":"Contributors, A.B.: Apache beam: an advanced unified programming model (2020). https:\/\/beam.apache.org\/\/. Accessed 10 Aug 2020"},{"key":"43_CR10","unstructured":"Contributors, A.C.: Apache calcite: Streaming (2020). https:\/\/calcite.apache.org\/docs\/stream.html\/. Accessed 10 Aug 2020"},{"key":"43_CR11","unstructured":"dataArtisans: dataartisans\/yahoo-streaming-benchmark (2019). https:\/\/github.com\/dataArtisans\/yahoo-streaming-benchmark"},{"key":"43_CR12","unstructured":"Grier, J.: Extending the Yahoo! Streaming benchmark (2016). https:\/\/www.ververica.com\/blog\/extending-the-yahoo-streaming-benchmark. Accessed 15 May 2019"},{"key":"43_CR13","doi-asserted-by":"crossref","unstructured":"Li, B., Zhang, Z., Zheng, T., Zhong, Q., Huang, Q., Cheng, X.: Marabunta: continuous distributed processing of skewed streams. In: 2020 20th IEEE\/ACM International Symposium on Cluster, Cloud and Internet Computing (CCGRID), pp. 252\u2013261. IEEE (2020)","DOI":"10.1109\/CCGrid49817.2020.00-68"},{"key":"43_CR14","doi-asserted-by":"publisher","unstructured":"Nikolic, M., Dashti, M., Koch, C.: How to win a hot dog eating contest: Distributed incremental view maintenance with batch updates. In: Proceedings of the 2016 International Conference on Management of Data, SIGMOD 2016, pp. 511\u2013526. Association for Computing Machinery, New York (2016). https:\/\/doi.org\/10.1145\/2882903.2915246","DOI":"10.1145\/2882903.2915246"},{"key":"43_CR15","doi-asserted-by":"publisher","unstructured":"Schelter, S., Ewen, S., Tzoumas, K., Markl, V.: \u201cAll roads lead to Rome\u201d: Optimistic recovery for distributed iterative data processing. In: Proceedings of the 22Nd ACM International Conference on Information & Knowledge Management, CIKM 2013, pp. 1919\u20131928. ACM, New York (2013). https:\/\/doi.org\/10.1145\/2505515.2505753. http:\/\/doi.acm.org\/10.1145\/2505515.2505753","DOI":"10.1145\/2505515.2505753"},{"key":"43_CR16","unstructured":"Tu, Y.C., Liu, S., Prabhakar, S., Yao, B.: Load shedding in stream databases: a control-based approach. In: Proceedings of the 32nd International Conference on Very Large Data Bases, VLDB 2006, pp. 787\u2013798. VLDB Endowment (2006)"},{"key":"43_CR17","unstructured":"Vector, T.: Customer support on Twitter (2017). https:\/\/www.kaggle.com\/thoughtvector\/customer-support-on-twitter. Accessed 15 Oct 2018"},{"key":"43_CR18","unstructured":"W.Schneider, T.: Analyzing 1.1 billion NYC taxi and Uber trips, with a vengeance (2020). https:\/\/toddwschneider.com\/posts\/analyzing-1-1-billion-nyc-taxi-and-uber-trips-with-a-vengeance\/. Accessed 25 Aug 2020"},{"key":"43_CR19","doi-asserted-by":"publisher","unstructured":"Zaharia, M., Das, T., Li, H., Hunter, T., Shenker, S., Stoica, I.: Discretized streams: fault-tolerant streaming computation at scale. In: Proceedings of the Twenty-Fourth ACM Symposium on Operating Systems Principles, SOSP 2013, pp. 423\u2013438. ACM, New York (2013). https:\/\/doi.org\/10.1145\/2517349.2522737. http:\/\/doi.acm.org\/10.1145\/2517349.2522737","DOI":"10.1145\/2517349.2522737"},{"key":"43_CR20","doi-asserted-by":"publisher","unstructured":"Zeuch, S., et al.: Analyzing efficient stream processing on modern hardware. Proc. VLDB Endow. 12(5), 516\u2013530 (2019). https:\/\/doi.org\/10.14778\/3303753.3303758","DOI":"10.14778\/3303753.3303758"}],"container-title":["Lecture Notes in Computer Science","Algorithms and Architectures for Parallel Processing"],"original-title":[],"language":"en","link":[{"URL":"https:\/\/link.springer.com\/content\/pdf\/10.1007\/978-981-95-8411-6_43","content-type":"unspecified","content-version":"vor","intended-application":"similarity-checking"}],"deposited":{"date-parts":[[2026,3,30]],"date-time":"2026-03-30T17:09:42Z","timestamp":1774890582000},"score":1,"resource":{"primary":{"URL":"https:\/\/link.springer.com\/10.1007\/978-981-95-8411-6_43"}},"subtitle":[],"short-title":[],"issued":{"date-parts":[[2026]]},"ISBN":["9789819584109","9789819584116"],"references-count":20,"URL":"https:\/\/doi.org\/10.1007\/978-981-95-8411-6_43","relation":{},"ISSN":["0302-9743","1611-3349"],"issn-type":[{"value":"0302-9743","type":"print"},{"value":"1611-3349","type":"electronic"}],"subject":[],"published":{"date-parts":[[2026]]},"assertion":[{"value":"31 March 2026","order":1,"name":"first_online","label":"First Online","group":{"name":"ChapterHistory","label":"Chapter History"}},{"value":"ICA3PP","order":1,"name":"conference_acronym","label":"Conference Acronym","group":{"name":"ConferenceInfo","label":"Conference Information"}},{"value":"International Conference on Algorithms and Architectures for Parallel Processing","order":2,"name":"conference_name","label":"Conference Name","group":{"name":"ConferenceInfo","label":"Conference Information"}},{"value":"Zhengzhou","order":3,"name":"conference_city","label":"Conference City","group":{"name":"ConferenceInfo","label":"Conference Information"}},{"value":"China","order":4,"name":"conference_country","label":"Conference Country","group":{"name":"ConferenceInfo","label":"Conference Information"}},{"value":"2025","order":5,"name":"conference_year","label":"Conference Year","group":{"name":"ConferenceInfo","label":"Conference Information"}},{"value":"30 October 2025","order":7,"name":"conference_start_date","label":"Conference Start Date","group":{"name":"ConferenceInfo","label":"Conference Information"}},{"value":"2 November 2025","order":8,"name":"conference_end_date","label":"Conference End Date","group":{"name":"ConferenceInfo","label":"Conference Information"}},{"value":"25","order":9,"name":"conference_number","label":"Conference Number","group":{"name":"ConferenceInfo","label":"Conference Information"}},{"value":"ica3pp2025","order":10,"name":"conference_id","label":"Conference ID","group":{"name":"ConferenceInfo","label":"Conference Information"}},{"value":"https:\/\/ieee-cybermatics.org\/2025\/ica3pp\/","order":11,"name":"conference_url","label":"Conference URL","group":{"name":"ConferenceInfo","label":"Conference Information"}}]}}