{"status":"ok","message-type":"work","message-version":"1.0.0","message":{"indexed":{"date-parts":[[2026,4,15]],"date-time":"2026-04-15T08:12:33Z","timestamp":1776240753053,"version":"3.50.1"},"reference-count":36,"publisher":"Springer Science and Business Media LLC","issue":"10","license":[{"start":{"date-parts":[[2021,3,24]],"date-time":"2021-03-24T00:00:00Z","timestamp":1616544000000},"content-version":"tdm","delay-in-days":0,"URL":"https:\/\/www.springer.com\/tdm"},{"start":{"date-parts":[[2021,3,24]],"date-time":"2021-03-24T00:00:00Z","timestamp":1616544000000},"content-version":"vor","delay-in-days":0,"URL":"https:\/\/www.springer.com\/tdm"}],"funder":[{"DOI":"10.13039\/501100010193","name":"Korea Electric Power Corporation","doi-asserted-by":"publisher","award":["R18XA05"],"award-info":[{"award-number":["R18XA05"]}],"id":[{"id":"10.13039\/501100010193","id-type":"DOI","asserted-by":"publisher"}]},{"DOI":"10.13039\/501100003725","name":"National Research Foundation of Korea","doi-asserted-by":"publisher","award":["NRF-2019R1A2C1085311"],"award-info":[{"award-number":["NRF-2019R1A2C1085311"]}],"id":[{"id":"10.13039\/501100003725","id-type":"DOI","asserted-by":"publisher"}]}],"content-domain":{"domain":["link.springer.com"],"crossmark-restriction":false},"short-container-title":["J Supercomput"],"published-print":{"date-parts":[[2021,10]]},"DOI":"10.1007\/s11227-021-03725-4","type":"journal-article","created":{"date-parts":[[2021,3,24]],"date-time":"2021-03-24T12:02:40Z","timestamp":1616587360000},"page":"11353-11389","update-policy":"https:\/\/doi.org\/10.1007\/springer_crossmark_policy","source":"Crossref","is-referenced-by-count":5,"title":["Stochastic distributed data stream partitioning using task locality: design, implementation, and optimization"],"prefix":"10.1007","volume":"77","author":[{"given":"Siwoon","family":"Son","sequence":"first","affiliation":[],"role":[{"role":"author","vocabulary":"crossref"}]},{"given":"Hyeonseung","family":"Im","sequence":"additional","affiliation":[],"role":[{"role":"author","vocabulary":"crossref"}]},{"ORCID":"https:\/\/orcid.org\/0000-0002-2396-0405","authenticated-orcid":false,"given":"Yang-Sae","family":"Moon","sequence":"additional","affiliation":[],"role":[{"role":"author","vocabulary":"crossref"}]}],"member":"297","published-online":{"date-parts":[[2021,3,24]]},"reference":[{"issue":"10","key":"3725_CR1","first-page":"13","volume":"46","author":"JA Silva","year":"2013","unstructured":"Silva JA, Faria ER, Barros RC, Hruschka ER, de Carvalho A, Gama J (2013) Data stream clustering: a survey. ACM Comput Sur 46(10):13","journal-title":"ACM Comput Sur"},{"key":"3725_CR2","doi-asserted-by":"publisher","DOI":"10.1007\/978-0-387-47534-9","volume-title":"Data streams: models and algorithms","author":"CC Aggarwal","year":"2007","unstructured":"Aggarwal CC (2007) Data streams: models and algorithms. Springer-Verlag, Berlin"},{"issue":"12","key":"3725_CR3","doi-asserted-by":"publisher","first-page":"249","DOI":"10.3390\/fi11120249","volume":"11","author":"I Bartolini","year":"2019","unstructured":"Bartolini I, Patella M (2019) Real-time stream processing in social networks with RAM3S. Future Internet 11(12):249","journal-title":"Future Internet"},{"issue":"2","key":"3725_CR4","doi-asserted-by":"publisher","first-page":"1314","DOI":"10.1109\/COMST.2018.2882064","volume":"21","author":"X Wang","year":"2019","unstructured":"Wang X, Ning Z, Zhou M, Hu X, Wang L, Zhang Y, Yu FR, Hu B (2019) Privacy-preserving content dissemination for vehicular social networks: challenges and solutions. IEEE Commun Surv Tutor 21(2):1314\u20131345","journal-title":"IEEE Commun Surv Tutor"},{"issue":"52","key":"3725_CR5","first-page":"1","volume":"6","author":"H Nasiri","year":"2019","unstructured":"Nasiri H, Nasehi S, Goudarzi M (2019) Evaluation of distributed stream processing frameworks for IoT applications in smart cities. J Big Data 6(52):1\u201324","journal-title":"J Big Data"},{"issue":"11","key":"3725_CR6","doi-asserted-by":"publisher","first-page":"1939","DOI":"10.1109\/TSMC.2017.2780618","volume":"48","author":"G Fortino","year":"2018","unstructured":"Fortino G, Russo W, Savaglio C, Shen W, Zhou M (2018) Agent-oriented cooperative smart objects: from IoT system design to implementation. IEEE Trans Syst Man Cybern Syst 48(11):1939\u20131956","journal-title":"IEEE Trans Syst Man Cybern Syst"},{"key":"3725_CR7","doi-asserted-by":"publisher","first-page":"262","DOI":"10.1016\/j.jnca.2017.10.011","volume":"103","author":"K Gai","year":"2018","unstructured":"Gai K, Qiu M, Sun X (2018) A survey on fintech. J Netw Comput Appl 103:262\u2013273","journal-title":"J Netw Comput Appl"},{"key":"3725_CR8","doi-asserted-by":"crossref","unstructured":"Carvalho O, Roloff E, Navaux POA (Dec. 2017) \u201cA Distributed stream processing based architecture for IoT smart grids monitoring,\u201d In: Proc. of the 10th Int\u2019l Conf. on Utility and Cloud Computing, Austin, Texas, pp. 9-14,","DOI":"10.1145\/3147234.3148105"},{"issue":"1","key":"3725_CR9","doi-asserted-by":"publisher","first-page":"64","DOI":"10.1109\/JAS.2019.1911324","volume":"6","author":"Z Sheng","year":"2019","unstructured":"Sheng Z, Pfersich S, Eldridge A, Zhou J, Tian D, Leung VCM (2019) Wireless acoustic sensor networks and edge computing for rapid acoustic monitoring. IEEE\/CAA J Automatica Sinica 6(1):64\u201374","journal-title":"IEEE\/CAA J Automatica Sinica"},{"key":"3725_CR10","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 (June 2014) \u201cStorm @Twitter,\u201d In Proc. of the Int\u2019l Conf. on Management of Data, ACM SIGMOD, Snowbird, Utah, pp. 147-156","DOI":"10.1145\/2588555.2595641"},{"key":"3725_CR11","volume-title":"Storm blueprints: patterns for distributed real-time computation","author":"P Goetz","year":"2014","unstructured":"Goetz P, O\u2019Neill B (2014) Storm blueprints: patterns for distributed real-time computation. Packt Publishing Ltd, Birmingham"},{"issue":"1","key":"3725_CR12","doi-asserted-by":"publisher","first-page":"9","DOI":"10.14445\/22312803\/IJCTT-V19P103","volume":"19","author":"MH Iqbal","year":"2015","unstructured":"Iqbal MH, Soomro TR (2015) Big data analysis: apache storm perspective. Int\u2019l J Comput Trends Technol 19(1):9\u201314","journal-title":"Int\u2019l J Comput Trends Technol"},{"issue":"1","key":"3725_CR13","first-page":"7","volume":"15","author":"AG Shoro","year":"2015","unstructured":"Shoro AG, Soomro TR (2015) Big data analysis: apache spark perspective. Global J Comput Sci Technol 15(1):7\u201314","journal-title":"Global J Comput Sci Technol"},{"issue":"4","key":"3725_CR14","first-page":"28","volume":"36","author":"P Carbone","year":"2015","unstructured":"Carbone P, Even S, Haridi S (2015) Apache flink: stream and batch processing in a single engine. Bull IEEE Comput Soc Tech Comm data Eng 36(4):28\u201338","journal-title":"Bull IEEE Comput Soc Tech Comm data Eng"},{"key":"3725_CR15","doi-asserted-by":"crossref","unstructured":"Noghabi SA, Paramasivam K, Pan Y, Ramesh N, Bringhurst J, Gupta I, Campbell RH (2017) Samza: Stateful scalable stream processing at LinkedIn. Proc. of the VLDB Endowment 10(12):1634\u20131645","DOI":"10.14778\/3137765.3137770"},{"key":"3725_CR16","doi-asserted-by":"crossref","unstructured":"Shvachko K, Kuang H, Radia S, Chansler R (May 2010) \u201cThe Hadoop Distributed File System,\u201d In: Proc. of the IEEE 26th Symp. on Mass Storage Systems and Technologies, Incline Village, Nevada, pp. 1-10","DOI":"10.1109\/MSST.2010.5496972"},{"issue":"1","key":"3725_CR17","doi-asserted-by":"publisher","first-page":"72","DOI":"10.1145\/1629175.1629198","volume":"54","author":"J Dean","year":"2010","unstructured":"Dean J, Ghemawat S (2010) MapReduce: a flexible data processing tool. Comm ACM 54(1):72\u201377","journal-title":"Comm ACM"},{"issue":"1","key":"3725_CR18","doi-asserted-by":"publisher","first-page":"53","DOI":"10.1109\/TCYB.2014.2318898","volume":"45","author":"B Liu","year":"2015","unstructured":"Liu B, Huang K, Li J, Zhou M (2015) An Incremental and distributed inference method for large-scale ontologies based on MapReduce paradigm. IEEE Trans Cybern 45(1):53\u201364","journal-title":"IEEE Trans Cybern"},{"key":"3725_CR19","doi-asserted-by":"crossref","unstructured":"Guo Z, Fox G, Zhou M (May 2012) Investigation of Data locality in MapReduce, In: Proc. of the 12th IEEE\/ACM Int\u2019l Symp. on Cluster, Cloud and Grid Computing, Ottawa, Canada, pp. 419-426","DOI":"10.1109\/CCGrid.2012.42"},{"key":"3725_CR20","doi-asserted-by":"crossref","unstructured":"Park J, Lee D, Kim B, Huh J, Maeng S (June 2012) Locality-aware dynamic VM reconfiguration on MapReduce clouds, In: Proc. of the 21st Int\u2019l Symp. on High-performance Parallel and Distributed Computing, Delft, The Netherlands, pp. 27-36","DOI":"10.1145\/2287076.2287082"},{"key":"3725_CR21","doi-asserted-by":"crossref","unstructured":"Chen T-Y, Wei H-W, Wei M-F, Chen Y-J, Hsu T-S, Shih W-K (May 2013) LaSA: a locality-aware scheduling algorithm for Hadoop-MapReduce resource assignment, In: Proc. of the 2013 Int\u2019l Conf. on Collaboration Technologies and Systems, San Diego, California, pp. 342-346","DOI":"10.1109\/CTS.2013.6567252"},{"issue":"1","key":"3725_CR22","doi-asserted-by":"publisher","first-page":"190","DOI":"10.1109\/TNET.2014.2362745","volume":"24","author":"W Wang","year":"2016","unstructured":"Wang W, Zhu K, Ying L, Tan J, Zhang L (2016) MapTask scheduling in MapReduce with data locality: throughput and heavy-traffic optimality. J EEE\/ACM Trans Netw 24(1):190\u2013203","journal-title":"J EEE\/ACM Trans Netw"},{"key":"3725_CR23","doi-asserted-by":"crossref","unstructured":"Zaharia M, Borthakur D, Sarma JS, Elmeleegy K, Shenker S, Stoica I (Apr. 2010) Delay scheduling: A simple technique for achieving locality and fairness in cluster scheduling, In: Proc. of the 5th European Conf. on Computer Systems, Paris, France, pp. 265-278","DOI":"10.1145\/1755913.1755940"},{"key":"3725_CR24","doi-asserted-by":"crossref","unstructured":"Bu X, Rao J, Xu C-Z (June 2013) Interference and Locality-aware task scheduling for MapReduce Applications in virtual clusters, In: Proc. of the 22nd Int\u2019l Symp. on High-performance Parallel and Distributed Computing, New York, New York, pp. 227-238","DOI":"10.1145\/2462902.2462904"},{"key":"3725_CR25","doi-asserted-by":"crossref","unstructured":"Palanisamy B, Singh A, Liu L, Jain B (Nov. 2011) Purlieus: locality-aware resource allocation for MapReduce in a cloud, In: Proc. of the 2011 Int\u2019l Conf. for High Performance Computing, Networking, Storage and Analysis, Seattle, Washington, pp. 58:1-58:11","DOI":"10.1145\/2063384.2063462"},{"key":"3725_CR26","unstructured":"Topologies for measuring Storm performance, Apache Storm https:\/\/github.com\/apache\/storm\/tree\/master\/examples\/storm-perf"},{"key":"3725_CR27","doi-asserted-by":"crossref","unstructured":"Wang C, Meng X, Guo Q, Weng Z, Yang C (Oct. 2016) OrientStream: A framework for dynamic resource allocation in distributed data stream management systems, In: Proc. of the 25th ACM Int\u2019l Conf. on Information and Knowledge Management, Indianapolis, Indiana, pp. 2281-2286","DOI":"10.1145\/2983323.2983681"},{"issue":"12","key":"3725_CR28","doi-asserted-by":"publisher","first-page":"2669","DOI":"10.1109\/TKDE.2017.2751606","volume":"29","author":"C Wang","year":"2017","unstructured":"Wang C, Meng X, Guo Q, Weng Z, Yang C (2017) Automating characterization deployment in distributed data stream management systems. IEEE Trans Knowl Data Eng 29(12):2669\u20132681","journal-title":"IEEE Trans Knowl Data Eng"},{"key":"3725_CR29","doi-asserted-by":"crossref","unstructured":"Caneill M, Rheddane AE, Leroy V, Palma ND (Dec. 2016) Locality-aware routing in stateful streaming applications, In: Proc. of the 17th Int\u2019l Middleware Conf., Trento, Italy, pp. 4:1-4:13","DOI":"10.1145\/2988336.2988340"},{"key":"3725_CR30","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 HCM, Gedik B, Turaga DS (2014) Fundamentals of stream processing: application design, systems, and analytics. Cambridge University Press, Cambridge"},{"key":"3725_CR31","unstructured":"Moon Y-S, Whang K-Y, Loh W-K (Apr. 2001) Duality-based subsequence matching in time-series databases, In: Proc. the 17th IEEE Int\u2019l Conf. on Data Engineering, Heidelberg, Germany, pp. 263-272"},{"key":"3725_CR32","unstructured":"Apache Storm Concepts, https:\/\/storm.apache.org\/releases\/current\/Concepts.html"},{"key":"3725_CR33","doi-asserted-by":"crossref","unstructured":"Pelsser C, Cittadini L, Vissicchio S, Bush R (Oct. 2013) From Paris to Tokyo: on the Suitability of Ping to Measure Latency, In: Proc. of the 2013 Conf. on Internet Measurement Conference, Barcelona, Spain, pp. 427-432","DOI":"10.1145\/2504730.2504765"},{"key":"3725_CR34","unstructured":"Szalay A, Bunn J, Gray J, Foster I (2006) Raicu I the importance of data locality in distributed computing applications, NSF Workflow Workshop"},{"key":"3725_CR35","doi-asserted-by":"crossref","unstructured":"Son S, Lee S, Gil M-S, Choi M-J, Moon Y-S (Jan. 2018) Locality aware traffic distribution in apache storm for energy analytics platform, In: Proc. of the 6th IEEE Int\u2019l Conf. on Big Data and Smart Computing, Shanghai, China, pp. 721-724","DOI":"10.1109\/BigComp.2018.00135"},{"issue":"11","key":"3725_CR36","doi-asserted-by":"publisher","first-page":"1857","DOI":"10.3390\/electronics9111857","volume":"9","author":"S Son","year":"2020","unstructured":"Son S, Moon Y-S (2020) Locality\/fairness-aware job scheduling in distributed stream processing engines. Electronics 9(11):1857","journal-title":"Electronics"}],"container-title":["The Journal of Supercomputing"],"original-title":[],"language":"en","link":[{"URL":"https:\/\/link.springer.com\/content\/pdf\/10.1007\/s11227-021-03725-4.pdf","content-type":"application\/pdf","content-version":"vor","intended-application":"text-mining"},{"URL":"https:\/\/link.springer.com\/article\/10.1007\/s11227-021-03725-4\/fulltext.html","content-type":"text\/html","content-version":"vor","intended-application":"text-mining"},{"URL":"https:\/\/link.springer.com\/content\/pdf\/10.1007\/s11227-021-03725-4.pdf","content-type":"application\/pdf","content-version":"vor","intended-application":"similarity-checking"}],"deposited":{"date-parts":[[2021,9,8]],"date-time":"2021-09-08T09:16:48Z","timestamp":1631092608000},"score":1,"resource":{"primary":{"URL":"https:\/\/link.springer.com\/10.1007\/s11227-021-03725-4"}},"subtitle":[],"short-title":[],"issued":{"date-parts":[[2021,3,24]]},"references-count":36,"journal-issue":{"issue":"10","published-print":{"date-parts":[[2021,10]]}},"alternative-id":["3725"],"URL":"https:\/\/doi.org\/10.1007\/s11227-021-03725-4","relation":{},"ISSN":["0920-8542","1573-0484"],"issn-type":[{"value":"0920-8542","type":"print"},{"value":"1573-0484","type":"electronic"}],"subject":[],"published":{"date-parts":[[2021,3,24]]},"assertion":[{"value":"5 March 2021","order":1,"name":"accepted","label":"Accepted","group":{"name":"ArticleHistory","label":"Article History"}},{"value":"24 March 2021","order":2,"name":"first_online","label":"First Online","group":{"name":"ArticleHistory","label":"Article History"}}]}}