{"status":"ok","message-type":"work","message-version":"1.0.0","message":{"indexed":{"date-parts":[[2026,5,29]],"date-time":"2026-05-29T02:03:20Z","timestamp":1780020200643,"version":"3.53.1"},"reference-count":35,"publisher":"Elsevier BV","license":[{"start":{"date-parts":[[2026,9,1]],"date-time":"2026-09-01T00:00:00Z","timestamp":1788220800000},"content-version":"tdm","delay-in-days":0,"URL":"https:\/\/www.elsevier.com\/tdm\/userlicense\/1.0\/"},{"start":{"date-parts":[[2026,9,1]],"date-time":"2026-09-01T00:00:00Z","timestamp":1788220800000},"content-version":"tdm","delay-in-days":0,"URL":"https:\/\/www.elsevier.com\/legal\/tdmrep-license"},{"start":{"date-parts":[[2026,9,1]],"date-time":"2026-09-01T00:00:00Z","timestamp":1788220800000},"content-version":"stm-asf","delay-in-days":0,"URL":"https:\/\/doi.org\/10.15223\/policy-017"},{"start":{"date-parts":[[2026,9,1]],"date-time":"2026-09-01T00:00:00Z","timestamp":1788220800000},"content-version":"stm-asf","delay-in-days":0,"URL":"https:\/\/doi.org\/10.15223\/policy-037"},{"start":{"date-parts":[[2026,9,1]],"date-time":"2026-09-01T00:00:00Z","timestamp":1788220800000},"content-version":"stm-asf","delay-in-days":0,"URL":"https:\/\/doi.org\/10.15223\/policy-012"},{"start":{"date-parts":[[2026,9,1]],"date-time":"2026-09-01T00:00:00Z","timestamp":1788220800000},"content-version":"stm-asf","delay-in-days":0,"URL":"https:\/\/doi.org\/10.15223\/policy-029"},{"start":{"date-parts":[[2026,9,1]],"date-time":"2026-09-01T00:00:00Z","timestamp":1788220800000},"content-version":"stm-asf","delay-in-days":0,"URL":"https:\/\/doi.org\/10.15223\/policy-004"}],"content-domain":{"domain":["elsevier.com","sciencedirect.com"],"crossmark-restriction":true},"short-container-title":["Future Generation Computer Systems"],"published-print":{"date-parts":[[2026,9]]},"DOI":"10.1016\/j.future.2026.108520","type":"journal-article","created":{"date-parts":[[2026,4,14]],"date-time":"2026-04-14T13:13:46Z","timestamp":1776172426000},"page":"108520","update-policy":"https:\/\/doi.org\/10.1016\/elsevier_cm_policy","source":"Crossref","is-referenced-by-count":0,"special_numbering":"C","title":["Stream-aware and parameter self-adaptive data partitioning algorithm for fluctuating data stream processing"],"prefix":"10.1016","volume":"182","author":[{"given":"Yifan","family":"Ren","sequence":"first","affiliation":[],"role":[{"vocabulary":"crossref","role":"author"}]},{"ORCID":"https:\/\/orcid.org\/0000-0002-8558-0838","authenticated-orcid":false,"given":"Hongjian","family":"Li","sequence":"additional","affiliation":[],"role":[{"vocabulary":"crossref","role":"author"}]}],"member":"78","reference":[{"key":"10.1016\/j.future.2026.108520_b1","doi-asserted-by":"crossref","first-page":"171","DOI":"10.1007\/s11036-013-0489-0","article-title":"Big data: a survey","volume":"19","author":"Chen","year":"2014","journal-title":"Mob. Netw. Appl."},{"key":"10.1016\/j.future.2026.108520_b2","doi-asserted-by":"crossref","unstructured":"Z.A. Al-Sai, R. Abdullah, A review on big data maturity models, in: 2019 IEEE Jordan International Joint Conference on Electrical Engineering and Information Technology, JEEIT, Amman, Jordan, 2019, pp. 156\u2013161.","DOI":"10.1109\/JEEIT.2019.8717398"},{"key":"10.1016\/j.future.2026.108520_b3","doi-asserted-by":"crossref","unstructured":"G. Hass, P. Simon, R. Kashef, Business applications for current developments in big data clustering: an overview, in: 2020 IEEE International Conference on Industrial Engineering and Engineering Management, IEEM, Singapore, Singapore, 2020, pp. 195\u2013199.","DOI":"10.1109\/IEEM45057.2020.9309941"},{"issue":"3","key":"10.1016\/j.future.2026.108520_b4","doi-asserted-by":"crossref","first-page":"1","DOI":"10.1145\/3355399","article-title":"Resource management and scheduling in distributed stream processing systems: a taxonomy, review, and future directions","volume":"53","author":"Liu","year":"2020","journal-title":"ACM Comput. Surv."},{"issue":"7","key":"10.1016\/j.future.2026.108520_b5","doi-asserted-by":"crossref","first-page":"6679","DOI":"10.1109\/TITS.2021.3060576","article-title":"A dynamic pyramid tilling method for traffic data stream based on flink","volume":"23","author":"Hu","year":"2021","journal-title":"IEEE Trans. Intell. Transp. Syst."},{"key":"10.1016\/j.future.2026.108520_b6","first-page":"1","article-title":"A two-tier coordinated load balancing strategy over skewed data streams","author":"Sun","year":"2023","journal-title":"J. Supercomput."},{"key":"10.1016\/j.future.2026.108520_b7","doi-asserted-by":"crossref","unstructured":"K. Lang, X. Chai, Implementation of load balancing algorithm based on Flink cluster, in: 2022 International Conference on Cloud Computing, Big Data Applications and Software Engineering, CBASE, Suzhou, China, 2022, pp. 264\u2013268.","DOI":"10.1109\/CBASE57816.2022.00058"},{"key":"10.1016\/j.future.2026.108520_b8","article-title":"Cost-efficient scheduling of streaming applications in apache Flink on cloud","author":"Li","year":"2022","journal-title":"IEEE Trans. Big Data"},{"key":"10.1016\/j.future.2026.108520_b9","doi-asserted-by":"crossref","first-page":"11353","DOI":"10.1007\/s11227-021-03725-4","article-title":"Stochastic distributed data stream partitioning using task locality: design, implementation, and optimization","volume":"77","author":"Son","year":"2021","journal-title":"J. Supercomput."},{"key":"10.1016\/j.future.2026.108520_b10","doi-asserted-by":"crossref","first-page":"117","DOI":"10.1016\/j.future.2021.10.005","article-title":"A multi-level collaborative framework for elastic stream computing systems","volume":"128","author":"Sun","year":"2022","journal-title":"Future Gener. Comput. Syst."},{"key":"10.1016\/j.future.2026.108520_b11","doi-asserted-by":"crossref","unstructured":"J. Karimov, H.A. Jacobsen, SASPAR: shared adaptive stream partitioning, in: 2023 IEEE 39th International Conference on Data Engineering, ICDE, Anaheim, CA, USA, 2023, pp. 922\u2013935.","DOI":"10.1109\/ICDE55515.2023.00076"},{"issue":"3","key":"10.1016\/j.future.2026.108520_b12","first-page":"1","article-title":"A three-tier load balancing model with dynamic data partitioning strategy for distributed stream processing","volume":"24","author":"Li","year":"2026","journal-title":"J. Grid Comput."},{"key":"10.1016\/j.future.2026.108520_b13","doi-asserted-by":"crossref","unstructured":"C. He, Y. Huang, C. Wang, et al., Dynamic data partitioning strategy based on heterogeneous Flink cluster, in: 2022 5th International Conference on Artificial Intelligence and Big Data, ICAIBD, Chengdu, China, 2022, pp. 355\u2013360.","DOI":"10.1109\/ICAIBD55127.2022.9820336"},{"key":"10.1016\/j.future.2026.108520_b14","doi-asserted-by":"crossref","first-page":"193","DOI":"10.1016\/j.future.2020.05.021","article-title":"Dynamic redirection of real-time data streams for elastic stream computing","volume":"112","author":"Sun","year":"2020","journal-title":"Future Gener. Comput. Syst."},{"issue":"8","key":"10.1016\/j.future.2026.108520_b15","doi-asserted-by":"crossref","DOI":"10.1109\/TPDS.2021.3051059","article-title":"Hone: mitigating stragglers in distributed stream processing with tuple scheduling","volume":"32","author":"Li","year":"2021","journal-title":"IEEE Trans. Parallel Distrib. Syst."},{"key":"10.1016\/j.future.2026.108520_b16","doi-asserted-by":"crossref","first-page":"138","DOI":"10.1016\/j.future.2023.11.002","article-title":"An adaptive load balancing strategy for stateful join operator in skewed data stream environments","volume":"152","author":"Sun","year":"2024","journal-title":"Future Gener. Comput. Syst."},{"key":"10.1016\/j.future.2026.108520_b17","doi-asserted-by":"crossref","unstructured":"D. Sun, Z. Chen, W. Lv, et al., A frequency-aware grouping strategy for stateful operators in distributed stream processing systems, in: 2023 IEEE 29th International Conference on Parallel and Distributed Systems, ICPADS, Ocean Flower Island, China, 2023, pp. 126\u2013131.","DOI":"10.1109\/ICPADS60453.2023.00027"},{"key":"10.1016\/j.future.2026.108520_b18","doi-asserted-by":"crossref","unstructured":"S. Lei, D. Sun, A. Saijanhar, An elastic scalable grouping for stateful operators in stream computing systems, in: International Conference on Advanced Data Mining and Applications, Shenyang, China, 2023, pp. 463\u2013478.","DOI":"10.1007\/978-3-031-46661-8_31"},{"issue":"14","key":"10.1016\/j.future.2026.108520_b19","doi-asserted-by":"crossref","DOI":"10.1002\/cpe.8085","article-title":"Lc-stream: an elastic scheduling strategy with latency constrained in geo-distributed stream computing environments","volume":"36","author":"Sun","year":"2024","journal-title":"Concurr. Comput.: Pract. Exp."},{"key":"10.1016\/j.future.2026.108520_b20","doi-asserted-by":"crossref","DOI":"10.1016\/j.eswa.2024.124346","article-title":"Orchestrating scheduling, grouping and parallelism to enhance the performance of distributed stream computing system","volume":"254","author":"Sun","year":"2024","journal-title":"Expert Syst. Appl."},{"issue":"3","key":"10.1016\/j.future.2026.108520_b21","doi-asserted-by":"crossref","first-page":"491","DOI":"10.14778\/3570690.3570699","article-title":"Dalton: Learned partitioning for distributed data streams","volume":"16","author":"Zapridou","year":"2022","journal-title":"Proc. VLDB Endow."},{"key":"10.1016\/j.future.2026.108520_b22","doi-asserted-by":"crossref","unstructured":"A. Aslam, G. Simonini, L. Gagliardelli, et al., HKS: Efficient Data Partitioning for Stateful Streaming, in: International Conference on Big Data Analytics and Knowledge Discovery, Penang, Malaysia, 2023, pp. 386\u2013391.","DOI":"10.1007\/978-3-031-39831-5_35"},{"issue":"2","key":"10.1016\/j.future.2026.108520_b23","doi-asserted-by":"crossref","first-page":"164","DOI":"10.1007\/s42514-023-00179-3","article-title":"Adaptive key partitioning in distributed stream processing","volume":"6","author":"Liu","year":"2024","journal-title":"CCF Trans. High Perform. Comput."},{"key":"10.1016\/j.future.2026.108520_b24","doi-asserted-by":"crossref","DOI":"10.1016\/j.future.2024.107673","article-title":"Straggler mitigation via hierarchical scheduling in elastic stream computing systems","volume":"166","author":"Wu","year":"2025","journal-title":"Future Gener. Comput. Syst."},{"key":"10.1016\/j.future.2026.108520_b25","doi-asserted-by":"crossref","unstructured":"Y. Pu, Optimization method based on data migration on metaverse, in: 2024 2nd International Conference on Intelligent Metaverse Technologies & Applications, IMETA, Dubai, United Arab Emirates, 2024, pp. 149\u2013155.","DOI":"10.1109\/iMETA62882.2024.10808091"},{"key":"10.1016\/j.future.2026.108520_b26","doi-asserted-by":"crossref","unstructured":"Z. Zvara, P.G.N. Szab\u00f3, B.B. L\u00f3r\u00e1nt, et al., System-aware dynamic partitioning for batch and streaming workloads, in: Proceedings of the 14th IEEE\/ACM International Conference on Utility and Cloud Computing, Leicester, United Kingdom, 2021, pp. 1\u201310.","DOI":"10.1145\/3468737.3494087"},{"issue":"1","key":"10.1016\/j.future.2026.108520_b27","doi-asserted-by":"crossref","first-page":"39","DOI":"10.1007\/s10723-024-09756-4","article-title":"Adaptive scheduling framework of streaming applications based on resource demand prediction with hybrid algorithms","volume":"22","author":"Li","year":"2024","journal-title":"J. Grid Comput."},{"issue":"2","key":"10.1016\/j.future.2026.108520_b28","doi-asserted-by":"crossref","first-page":"681","DOI":"10.1109\/TNET.2021.3050927","article-title":"Elasecutor: elastic executor scheduling in data analytics systems","volume":"29","author":"Liu","year":"2021","journal-title":"IEEE\/ACM Trans. Netw."},{"issue":"10","key":"10.1016\/j.future.2026.108520_b29","doi-asserted-by":"crossref","first-page":"1582","DOI":"10.1109\/TC.2020.3019689","article-title":"Pstream: a popularity-aware differentiated distributed stream processing system","volume":"70","author":"Chen","year":"2020","journal-title":"IEEE Trans. Comput."},{"key":"10.1016\/j.future.2026.108520_b30","doi-asserted-by":"crossref","DOI":"10.7717\/peerj-cs.2767","article-title":"WG-Storm: A resource-aware scheduler for distributed stream processing engines","volume":"11","author":"Ali","year":"2025","journal-title":"PeerJ Comput. Sci."},{"key":"10.1016\/j.future.2026.108520_b31","first-page":"1","article-title":"A resource occupancy ratio-oriented load balancing task scheduling mechanism for Flink","author":"Dai","year":"2023","journal-title":"J. Intell. Fuzzy Systems"},{"key":"10.1016\/j.future.2026.108520_b32","series-title":"Cloud Computing and Distributed Systems","first-page":"133","article-title":"Dynamic resource-efficient scheduling in data stream management systems deployed on computing clouds","author":"Liu","year":"2022"},{"key":"10.1016\/j.future.2026.108520_b33","doi-asserted-by":"crossref","DOI":"10.1016\/j.jnca.2024.103842","article-title":"A survey on intelligent management of alerts and incidents in IT services","volume":"224","author":"Yu","year":"2024","journal-title":"J. Netw. Comput. Appl."},{"key":"10.1016\/j.future.2026.108520_b34","doi-asserted-by":"crossref","first-page":"3686","DOI":"10.1038\/s41598-025-33133-0","article-title":"A direction aware predictive offloading framework for energy conscious mobile augmented reality systems","volume":"16","author":"Jebamani","year":"2026","journal-title":"Sci. Rep."},{"issue":"5","key":"10.1016\/j.future.2026.108520_b35","doi-asserted-by":"crossref","first-page":"3334","DOI":"10.1109\/TSC.2025.3603867","article-title":"Trident: A provider-oriented resource management framework for serverless computing platforms","volume":"18","author":"Zhu","year":"2025","journal-title":"IEEE Trans. Serv. Comput."}],"container-title":["Future Generation Computer Systems"],"original-title":[],"language":"en","link":[{"URL":"https:\/\/api.elsevier.com\/content\/article\/PII:S0167739X26001548?httpAccept=text\/xml","content-type":"text\/xml","content-version":"vor","intended-application":"text-mining"},{"URL":"https:\/\/api.elsevier.com\/content\/article\/PII:S0167739X26001548?httpAccept=text\/plain","content-type":"text\/plain","content-version":"vor","intended-application":"text-mining"}],"deposited":{"date-parts":[[2026,5,29]],"date-time":"2026-05-29T01:34:45Z","timestamp":1780018485000},"score":1,"resource":{"primary":{"URL":"https:\/\/linkinghub.elsevier.com\/retrieve\/pii\/S0167739X26001548"}},"subtitle":[],"short-title":[],"issued":{"date-parts":[[2026,9]]},"references-count":35,"alternative-id":["S0167739X26001548"],"URL":"https:\/\/doi.org\/10.1016\/j.future.2026.108520","relation":{},"ISSN":["0167-739X"],"issn-type":[{"value":"0167-739X","type":"print"}],"subject":[],"published":{"date-parts":[[2026,9]]},"assertion":[{"value":"Elsevier","name":"publisher","label":"This article is maintained by"},{"value":"Stream-aware and parameter self-adaptive data partitioning algorithm for fluctuating data stream processing","name":"articletitle","label":"Article Title"},{"value":"Future Generation Computer Systems","name":"journaltitle","label":"Journal Title"},{"value":"https:\/\/doi.org\/10.1016\/j.future.2026.108520","name":"articlelink","label":"CrossRef DOI link to publisher maintained version"},{"value":"article","name":"content_type","label":"Content Type"},{"value":"\u00a9 2026 Elsevier B.V. All rights are reserved, including those for text and data mining, AI training, and similar technologies.","name":"copyright","label":"Copyright"}],"article-number":"108520"}}