{"status":"ok","message-type":"work","message-version":"1.0.0","message":{"indexed":{"date-parts":[[2026,3,19]],"date-time":"2026-03-19T15:25:35Z","timestamp":1773933935214,"version":"3.50.1"},"reference-count":42,"publisher":"Springer Science and Business Media LLC","issue":"1","license":[{"start":{"date-parts":[[2025,11,21]],"date-time":"2025-11-21T00:00:00Z","timestamp":1763683200000},"content-version":"tdm","delay-in-days":0,"URL":"https:\/\/www.springernature.com\/gp\/researchers\/text-and-data-mining"},{"start":{"date-parts":[[2025,11,21]],"date-time":"2025-11-21T00:00:00Z","timestamp":1763683200000},"content-version":"vor","delay-in-days":0,"URL":"https:\/\/www.springernature.com\/gp\/researchers\/text-and-data-mining"}],"funder":[{"DOI":"10.13039\/501100001809","name":"National Natural Science Foundation of China","doi-asserted-by":"crossref","award":["No.62372419"],"award-info":[{"award-number":["No.62372419"]}],"id":[{"id":"10.13039\/501100001809","id-type":"DOI","asserted-by":"crossref"}]},{"DOI":"10.13039\/501100012226","name":"Fundamental Research Funds for the Central Universities","doi-asserted-by":"publisher","award":["No.265QZ2021001"],"award-info":[{"award-number":["No.265QZ2021001"]}],"id":[{"id":"10.13039\/501100012226","id-type":"DOI","asserted-by":"publisher"}]}],"content-domain":{"domain":["link.springer.com"],"crossmark-restriction":false},"short-container-title":["Cluster Comput"],"published-print":{"date-parts":[[2026,2]]},"DOI":"10.1007\/s10586-025-05808-w","type":"journal-article","created":{"date-parts":[[2025,11,21]],"date-time":"2025-11-21T19:09:47Z","timestamp":1763752187000},"update-policy":"https:\/\/doi.org\/10.1007\/springer_crossmark_policy","source":"Crossref","is-referenced-by-count":0,"title":["Pa-Stream: pattern-aware scheduling for distributed stream computing systems"],"prefix":"10.1007","volume":"29","author":[{"given":"Dawei","family":"Sun","sequence":"first","affiliation":[]},{"given":"Yinuo","family":"Fan","sequence":"additional","affiliation":[]},{"given":"Ning","family":"Zhang","sequence":"additional","affiliation":[]},{"given":"Shang","family":"Gao","sequence":"additional","affiliation":[]},{"given":"Jianguo","family":"Yu","sequence":"additional","affiliation":[]},{"given":"Rajkumar","family":"Buyya","sequence":"additional","affiliation":[]}],"member":"297","published-online":{"date-parts":[[2025,11,21]]},"reference":[{"issue":"2","key":"5808_CR1","doi-asserted-by":"publisher","first-page":"507","DOI":"10.1007\/s00778-023-00819-8","volume":"33","author":"M Fragkoulis","year":"2024","unstructured":"Fragkoulis, M., Carbone, P., Kalavri, V., Katsifodimos, A.: A survey on the evolution of stream processing systems. The VLDB Journal 33(2), 507\u2013541 (2024)","journal-title":"The VLDB Journal"},{"issue":"5","key":"5808_CR2","doi-asserted-by":"publisher","first-page":"5815","DOI":"10.1007\/s10586-023-04260-y","volume":"27","author":"H Hadian","year":"2024","unstructured":"Hadian, H., Sharifi, M.: Gt-scheduler: a hybrid graph-partitioning and tabu-search based task scheduler for distributed data stream processing systems. Cluster Computing 27(5), 5815\u20135832 (2024)","journal-title":"Cluster Computing"},{"key":"5808_CR3","doi-asserted-by":"publisher","DOI":"10.1016\/j.sysarc.2023.102894","volume":"140","author":"B Hu","year":"2023","unstructured":"Hu, B., Yang, X., Zhao, M.: Online energy-efficient scheduling of dag tasks on heterogeneous embedded platforms. Journal of Systems Architecture 140, 102894 (2023)","journal-title":"Journal of Systems Architecture"},{"issue":"3","key":"5808_CR4","doi-asserted-by":"publisher","first-page":"2741","DOI":"10.1007\/s10586-023-04065-z","volume":"27","author":"B Tang","year":"2024","unstructured":"Tang, B., Han, H., Yang, Q., Xu, W.: Operator placement for data stream processing based on publisher\/subscriber in hybrid cloud-fog-edge infrastructure. Cluster Computing 27(3), 2741\u20132759 (2024)","journal-title":"Cluster Computing"},{"key":"5808_CR5","doi-asserted-by":"publisher","DOI":"10.1109\/TCC.2025.3538512","author":"J Tan","year":"2025","unstructured":"Tan, J., Tang, Z., Cai, W., Tan, W.J., Xiao, X., Zhang, J., Gao, Y., Li, K.: A cost-aware operator migration approach for distributed stream processing system. IEEE Trans. Cloud Comput. (2025). https:\/\/doi.org\/10.1109\/TCC.2025.3538512","journal-title":"IEEE Trans. Cloud Comput."},{"key":"5808_CR6","doi-asserted-by":"publisher","DOI":"10.1016\/j.eswa.2021.116322","volume":"191","author":"M Farrokh","year":"2022","unstructured":"Farrokh, M., Hadian, H., Sharifi, M., Jafari, A.: Sp-ant: An ant colony optimization based operator scheduler for high performance distributed stream processing on heterogeneous clusters. Expert Systems with Applications 191, 116322 (2022)","journal-title":"Expert Systems with Applications"},{"key":"5808_CR7","doi-asserted-by":"publisher","first-page":"219","DOI":"10.1016\/j.future.2020.11.011","volume":"117","author":"L Eskandari","year":"2021","unstructured":"Eskandari, L., Mair, J., Huang, Z., Eyers, D.: I-scheduler: Iterative scheduling for distributed stream processing systems. Future Generation Computer Systems 117, 219\u2013233 (2021)","journal-title":"Future Generation Computer Systems"},{"key":"5808_CR8","doi-asserted-by":"publisher","first-page":"252","DOI":"10.1016\/j.future.2022.06.007","volume":"136","author":"D Sun","year":"2022","unstructured":"Sun, D., Cui, Y., Wu, M., Gao, S., Buyya, R.: An energy efficient and runtime-aware framework for distributed stream computing systems. Future Generation Computer Systems 136, 252\u2013269 (2022)","journal-title":"Future Generation Computer Systems"},{"key":"5808_CR9","doi-asserted-by":"publisher","first-page":"617","DOI":"10.1016\/j.future.2018.07.011","volume":"89","author":"L Eskandari","year":"2018","unstructured":"Eskandari, L., Mair, J., Huang, Z., Eyers, D.: T3-scheduler: A topology and traffic aware two-level scheduler for stream processing systems in a heterogeneous cluster. Future Generation Computer Systems 89, 617\u2013632 (2018)","journal-title":"Future Generation Computer Systems"},{"key":"5808_CR10","doi-asserted-by":"publisher","first-page":"417","DOI":"10.1007\/s10586-020-03117-y","volume":"24","author":"A Muhammad","year":"2021","unstructured":"Muhammad, A., Aleem, M., Islam, M.A.: Top-storm: A topology-based resource-aware scheduler for stream processing engine. Cluster Computing 24, 417\u2013431 (2021)","journal-title":"Cluster Computing"},{"key":"5808_CR11","doi-asserted-by":"crossref","unstructured":"Li, B., Sun, D., Chau, V.L., Buyya, R.: A topology-aware scheduling strategy for distributed stream computing system. In: Broadband Communications, Networks, and Systems: 12th EAI International Conference, BROADNETS 2021, Virtual Event, October 28\u201329, 2021, Proceedings 12, pp. 132\u2013147 (2022). Springer","DOI":"10.1007\/978-3-030-93479-8_8"},{"issue":"4","key":"5808_CR12","doi-asserted-by":"publisher","first-page":"2863","DOI":"10.1109\/TCC.2020.3032577","volume":"10","author":"X Huang","year":"2020","unstructured":"Huang, X., Shao, Z., Yang, Y.: Potus: Predictive online tuple scheduling for data stream processing systems. IEEE Transactions on Cloud Computing 10(4), 2863\u20132875 (2020)","journal-title":"IEEE Transactions on Cloud Computing"},{"key":"5808_CR13","doi-asserted-by":"publisher","DOI":"10.1016\/j.sysarc.2021.102385","volume":"124","author":"S Chang","year":"2022","unstructured":"Chang, S., Sun, J., Hao, Z., Deng, Q., Guan, N.: Computing exact wcrt for typed dag tasks on heterogeneous multi-core processors. Journal of Systems Architecture 124, 102385 (2022)","journal-title":"Journal of Systems Architecture"},{"key":"5808_CR14","doi-asserted-by":"publisher","DOI":"10.1016\/j.sysarc.2024.103084","volume":"148","author":"F Li","year":"2024","unstructured":"Li, F., Bi, R., Wang, J., Sun, J., Sun, Z., Tan, G., Chen, M.: Vpss: A dag scheduling heuristic with improved response time bound. Journal of Systems Architecture 148, 103084 (2024)","journal-title":"Journal of Systems Architecture"},{"key":"5808_CR15","unstructured":"Apache: Spark (2025). http:\/\/spark.apache.org\/ Accessed 2025-03-12"},{"key":"5808_CR16","unstructured":"Apache: Flink (2025). http:\/\/flink.apache.org\/ Accessed 2025-03-12"},{"key":"5808_CR17","doi-asserted-by":"publisher","first-page":"307","DOI":"10.1016\/j.future.2018.08.013","volume":"90","author":"I Mohiuddin","year":"2019","unstructured":"Mohiuddin, I., Almogren, A., Al Qurishi, M., Hassan, M.M., Al Rassan, I., Fortino, G.: Secure distributed adaptive bin packing algorithm for cloud storage. Future Generation Computer Systems 90, 307\u2013316 (2019)","journal-title":"Future Generation Computer Systems"},{"key":"5808_CR18","doi-asserted-by":"crossref","unstructured":"Tan, F., Yan, P., Guan, X.: Deep reinforcement learning: From q-learning to deep q-learning. In: Neural Information Processing: 24th International Conference, ICONIP 2017, Guangzhou, China, November 14\u201318, 2017, Proceedings, Part IV 24, pp. 475\u2013483 (2017). Springer","DOI":"10.1007\/978-3-319-70093-9_50"},{"key":"5808_CR19","unstructured":"Ernst, D., Louette, A.: Introduction to reinforcement learning. Feuerriegel, S., Hartmann, J., Janiesch, C., and Zschech, P, 111\u2013126 (2024)"},{"key":"5808_CR20","doi-asserted-by":"crossref","unstructured":"Peng, B., Hosseini, M., Hong, Z., Farivar, R., Campbell, R.: R-storm: Resource-aware scheduling in storm. In: Proceedings of the 16th Annual Middleware Conference, pp. 149\u2013161 (2015)","DOI":"10.1145\/2814576.2814808"},{"key":"5808_CR21","doi-asserted-by":"crossref","unstructured":"Kang, P., Khan, S.U., Zhou, X., Lama, P.: High-throughput real-time edge stream processing with topology-aware resource matching. In: 2024 IEEE 24th International Symposium on Cluster, Cloud and Internet Computing (CCGrid), pp. 385\u2013394 (2024). IEEE","DOI":"10.1109\/CCGrid59990.2024.00051"},{"key":"5808_CR22","doi-asserted-by":"publisher","DOI":"10.1016\/j.jpdc.2025.105041","volume":"199","author":"R Ecker","year":"2025","unstructured":"Ecker, R., Karagiannis, V., Sober, M., Schulte, S.: Latency-aware placement of stream processing operators in modern-day stream processing frameworks. Journal of Parallel and Distributed Computing 199, 105041 (2025)","journal-title":"Journal of Parallel and Distributed Computing"},{"key":"5808_CR23","unstructured":"Kalavri, V., Liagouris, J., Hoffmann, M., Dimitrova, D., Forshaw, M., Roscoe, T.: Three steps is all you need: fast, accurate, automatic scaling decisions for distributed streaming dataflows. In: 13th USENIX Symposium on Operating Systems Design and Implementation (OSDI 18), pp. 783\u2013798 (2018)"},{"key":"5808_CR24","doi-asserted-by":"publisher","DOI":"10.1109\/TMC.2025.3526143","author":"C-W Ching","year":"2025","unstructured":"Ching, C.-W., Chen, X., Kim, C., Wang, T., Chen, D., Da\u00a0Silva, D., Hu, L.: Agiledart: An agile and scalable edge stream processing engine. IEEE Transactions on Mobile Computing (2025). https:\/\/doi.org\/10.1109\/TMC.2025.3526143","journal-title":"IEEE Transactions on Mobile Computing"},{"issue":"12","key":"5808_CR25","doi-asserted-by":"publisher","first-page":"2624","DOI":"10.1109\/TPDS.2019.2922606","volume":"30","author":"S Maroulis","year":"2019","unstructured":"Maroulis, S., Zacheilas, N., Kalogeraki, V.: A holistic energy-efficient real-time scheduler for mixed stream and batch processing workloads. IEEE Trans. Parallel Distrib. Syst. 30(12), 2624\u20132635 (2019)","journal-title":"IEEE Trans. Parallel Distrib. Syst."},{"issue":"3","key":"5808_CR26","doi-asserted-by":"publisher","first-page":"491","DOI":"10.14778\/3570690.3570699","volume":"16","author":"E Zapridou","year":"2022","unstructured":"Zapridou, E., Mytilinis, I., Ailamaki, A.: Dalton: Learned partitioning for distributed data streams. Proceedings of the VLDB Endowment 16(3), 491\u2013504 (2022)","journal-title":"Proceedings of the VLDB Endowment"},{"key":"5808_CR27","unstructured":"Twitter, Inc.: Twitter Developer API Documentation (2022). https:\/\/developer.twitter.com\/en\/docs Accessed 2022-12-31"},{"issue":"5","key":"5808_CR28","first-page":"4446","volume":"35","author":"Q Cai","year":"2022","unstructured":"Cai, Q., Cui, C., Xiong, Y., Wang, W., Xie, Z., Zhang, M.: A survey on deep reinforcement learning for data processing and analytics. IEEE Trans. Knowl. Data Eng. 35(5), 4446\u20134465 (2022)","journal-title":"IEEE Trans. Knowl. Data Eng."},{"issue":"12","key":"5808_CR29","doi-asserted-by":"publisher","first-page":"9609","DOI":"10.1007\/s11227-020-03223-z","volume":"76","author":"A Al-Sinayyid","year":"2020","unstructured":"Al-Sinayyid, A., Zhu, M.: Job scheduler for streaming applications in heterogeneous distributed processing systems. J. Supercomput. 76(12), 9609\u20139628 (2020)","journal-title":"J. Supercomput."},{"issue":"1","key":"5808_CR30","doi-asserted-by":"publisher","first-page":"461","DOI":"10.1007\/s11227-022-04669-z","volume":"79","author":"H Hadian","year":"2023","unstructured":"Hadian, H., Farrokh, M., Sharifi, M., Jafari, A.: An elastic and traffic-aware scheduler for distributed data stream processing in heterogeneous clusters. J. Supercomput. 79(1), 461\u2013498 (2023)","journal-title":"J. Supercomput."},{"key":"5808_CR31","doi-asserted-by":"crossref","unstructured":"Silva\u00a0Veith, A., De\u00a0Souza, F.R., Assuncao, M.D., Lef\u00e8vre, L., Dos\u00a0Anjos, J.C.S.: Multi-objective reinforcement learning for reconfiguring data stream analytics on edge computing. In: Proceedings of the 48th International Conference on Parallel Processing, pp. 1\u201310 (2019)","DOI":"10.1145\/3337821.3337894"},{"key":"5808_CR32","doi-asserted-by":"crossref","unstructured":"Russo, G.R., Cardellini, V., Presti, F.L.: Reinforcement learning based policies for elastic stream processing on heterogeneous resources. In: Proceedings of the 13th ACM International Conference on Distributed and Event-Based Systems, pp. 31\u201342 (2019)","DOI":"10.1145\/3328905.3329506"},{"issue":"12","key":"5808_CR33","doi-asserted-by":"publisher","first-page":"1742","DOI":"10.14778\/3229863.3229864","volume":"11","author":"S Li","year":"2018","unstructured":"Li, S., Gerver, P., MacMillan, J., Debrunner, D., Marshall, W., Wu, K.-L.: Challenges and experiences in building an efficient apache beam runner for ibm streams. Proceedings of the VLDB Endowment 11(12), 1742\u20131754 (2018)","journal-title":"Proceedings of the VLDB Endowment"},{"key":"5808_CR34","doi-asserted-by":"crossref","unstructured":"Li, W., Wang, Y., Ma, W., Wang, L., Lv, D., Liu, H.: Containerized scheduling method based on kubernetes and yarn in big data scenarios. In: Proceedings of the 11th International Conference on Computer Engineering and Networks, pp. 1339\u20131350 (2021). Springer","DOI":"10.1007\/978-981-16-6554-7_149"},{"issue":"3","key":"5808_CR35","doi-asserted-by":"publisher","DOI":"10.1002\/widm.1405","volume":"11","author":"M Bahri","year":"2021","unstructured":"Bahri, M., Bifet, A., Gama, J., Gomes, H.M., Maniu, S.: Data stream analysis: Foundations, major tasks and tools. WIREs Data Mining and Knowledge Discovery 11(3), 1405 (2021)","journal-title":"WIREs Data Mining and Knowledge Discovery"},{"key":"5808_CR36","doi-asserted-by":"publisher","first-page":"1469","DOI":"10.1007\/s10994-017-5642-8","volume":"106","author":"HM Gomes","year":"2017","unstructured":"Gomes, H.M., Bifet, A., Read, J., Barddal, J.P., Enembreck, F., Pfharinger, B., Holmes, G., Abdessalem, T.: Adaptive random forests for evolving data stream classification. Mach. Learn. 106, 1469\u20131495 (2017)","journal-title":"Mach. Learn."},{"key":"5808_CR37","doi-asserted-by":"crossref","unstructured":"Gomes, H.M., Read, J., Bifet, A.: Streaming random patches for evolving data stream classification. In: 2019 IEEE International Conference on Data Mining (ICDM), pp. 240\u2013249 (2019). IEEE","DOI":"10.1109\/ICDM.2019.00034"},{"key":"5808_CR38","doi-asserted-by":"crossref","unstructured":"Bahri, M., Gomes, H.M., Bifet, A., Maniu, S.: Cs-arf: compressed adaptive random forests for evolving data stream classification. In: 2020 International Joint Conference on Neural Networks (IJCNN), pp. 1\u20138 (2020). IEEE","DOI":"10.1109\/IJCNN48605.2020.9207188"},{"key":"5808_CR39","doi-asserted-by":"crossref","unstructured":"Pratama, M., Angelov, P.P., Lu, J., Lughofer, E., Seera, M., Lim, C.P.: A randomized neural network for data streams. In: 2017 International Joint Conference on Neural Networks (IJCNN), pp. 3423\u20133430 (2017). IEEE","DOI":"10.1109\/IJCNN.2017.7966286"},{"key":"5808_CR40","doi-asserted-by":"publisher","first-page":"195","DOI":"10.1016\/j.jss.2016.06.009","volume":"127","author":"D Marr\u00f3n","year":"2017","unstructured":"Marr\u00f3n, D., Read, J., Bifet, A., Navarro, N.: Data stream classification using random feature functions and novel method combinations. Journal of Systems and Software 127, 195\u2013204 (2017)","journal-title":"Journal of Systems and Software"},{"issue":"110","key":"5808_CR41","first-page":"1","volume":"22","author":"J Montiel","year":"2021","unstructured":"Montiel, J., Halford, M., Mastelini, S.M., Bolmier, G., Sourty, R., Vaysse, R., Zouitine, A., Gomes, H.M., Read, J., Abdessalem, T., et al.: River: machine learning for streaming data in python. J. Mach. Learn. Res. 22(110), 1\u20138 (2021)","journal-title":"J. Mach. Learn. Res."},{"key":"5808_CR42","doi-asserted-by":"crossref","unstructured":"Bahri, M.: Effective weighted k-nearest neighbors for dynamic data streams. In: 2022 IEEE International Conference on Big Data (Big Data), pp. 3341\u20133347 (2022). IEEE","DOI":"10.1109\/BigData55660.2022.10020652"}],"container-title":["Cluster Computing"],"original-title":[],"language":"en","link":[{"URL":"https:\/\/link.springer.com\/content\/pdf\/10.1007\/s10586-025-05808-w.pdf","content-type":"application\/pdf","content-version":"vor","intended-application":"text-mining"},{"URL":"https:\/\/link.springer.com\/article\/10.1007\/s10586-025-05808-w","content-type":"text\/html","content-version":"vor","intended-application":"text-mining"},{"URL":"https:\/\/link.springer.com\/content\/pdf\/10.1007\/s10586-025-05808-w.pdf","content-type":"application\/pdf","content-version":"vor","intended-application":"similarity-checking"}],"deposited":{"date-parts":[[2026,3,19]],"date-time":"2026-03-19T13:08:03Z","timestamp":1773925683000},"score":1,"resource":{"primary":{"URL":"https:\/\/link.springer.com\/10.1007\/s10586-025-05808-w"}},"subtitle":[],"short-title":[],"issued":{"date-parts":[[2025,11,21]]},"references-count":42,"journal-issue":{"issue":"1","published-print":{"date-parts":[[2026,2]]}},"alternative-id":["5808"],"URL":"https:\/\/doi.org\/10.1007\/s10586-025-05808-w","relation":{},"ISSN":["1386-7857","1573-7543"],"issn-type":[{"value":"1386-7857","type":"print"},{"value":"1573-7543","type":"electronic"}],"subject":[],"published":{"date-parts":[[2025,11,21]]},"assertion":[{"value":"15 March 2025","order":1,"name":"received","label":"Received","group":{"name":"ArticleHistory","label":"Article History"}},{"value":"10 October 2025","order":2,"name":"revised","label":"Revised","group":{"name":"ArticleHistory","label":"Article History"}},{"value":"22 October 2025","order":3,"name":"accepted","label":"Accepted","group":{"name":"ArticleHistory","label":"Article History"}},{"value":"21 November 2025","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 declare no competing interests.","order":2,"name":"Ethics","group":{"name":"EthicsHeading","label":"Competing interests"}}],"article-number":"52"}}