{"status":"ok","message-type":"work","message-version":"1.0.0","message":{"indexed":{"date-parts":[[2025,10,23]],"date-time":"2025-10-23T11:22:05Z","timestamp":1761218525720,"version":"3.37.3"},"reference-count":18,"publisher":"Springer Science and Business Media LLC","issue":"5","license":[{"start":{"date-parts":[[2022,10,14]],"date-time":"2022-10-14T00:00:00Z","timestamp":1665705600000},"content-version":"tdm","delay-in-days":0,"URL":"https:\/\/www.springernature.com\/gp\/researchers\/text-and-data-mining"},{"start":{"date-parts":[[2022,10,14]],"date-time":"2022-10-14T00:00:00Z","timestamp":1665705600000},"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":["Cluster Comput"],"published-print":{"date-parts":[[2023,10]]},"DOI":"10.1007\/s10586-022-03758-1","type":"journal-article","created":{"date-parts":[[2022,10,14]],"date-time":"2022-10-14T21:02:42Z","timestamp":1665781362000},"page":"2773-2787","update-policy":"https:\/\/doi.org\/10.1007\/springer_crossmark_policy","source":"Crossref","is-referenced-by-count":2,"title":["zStream: towards a low latency micro-batch streaming system"],"prefix":"10.1007","volume":"26","author":[{"given":"Suyeon","family":"Lee","sequence":"first","affiliation":[]},{"given":"Yeonwoo","family":"Jeong","sequence":"additional","affiliation":[]},{"given":"Kyuli","family":"Park","sequence":"additional","affiliation":[]},{"given":"Gyeonghwan","family":"Jung","sequence":"additional","affiliation":[]},{"ORCID":"https:\/\/orcid.org\/0000-0002-0309-1820","authenticated-orcid":false,"given":"Sungyong","family":"Park","sequence":"additional","affiliation":[]}],"member":"297","published-online":{"date-parts":[[2022,10,14]]},"reference":[{"key":"3758_CR1","doi-asserted-by":"crossref","unstructured":"Lee, S.,\u00a0Jeong, Y.,\u00a0Kim, M.,\u00a0Park, S.: Q-spark: Qos aware micro-batch stream processing system using spark. In: 2021 IEEE International Conference on Autonomic Computing and Self-organizing Systems Companion (ACSOS-C), pp.\u00a038\u201343 (2021)","DOI":"10.1109\/ACSOS-C52956.2021.00027"},{"key":"3758_CR2","doi-asserted-by":"publisher","first-page":"42","DOI":"10.1145\/1107499.1107504","volume":"34","author":"M Stonebraker","year":"2005","unstructured":"Stonebraker, M., \u00c7etintemel, U., Zdonik, S.: The 8 requirements of real-time stream processing. SIGMOD Rec. 34, 42\u201347 (2005)","journal-title":"SIGMOD Rec."},{"key":"3758_CR3","volume-title":"Streaming Systems: The What, Where, When, and How of Large-Scale Data Processing","author":"T Akidau","year":"2018","unstructured":"Akidau, T., Chernyak, S., Lax, R.: Streaming Systems: The What, Where, When, and How of Large-Scale Data Processing. O\u2019Reilly Media Inc., Sebastopol (2018)"},{"key":"3758_CR4","unstructured":"Sun, D.,\u00a0Zhang, G.,\u00a0Zheng, W.,\u00a0Li, K.: Key technologies for big data stream computing. In: Big Data Algorithms, Analytics, and Applications, pp. 1\u201322. Chapman and Hall\/CRC (2004)"},{"key":"3758_CR5","unstructured":"Xu, L.,\u00a0Venkataraman, S.,\u00a0Gupta, I.,\u00a0Mai, L., Potharaju, R.: Move fast and meet deadlines: Fine-grained real-time stream processing with cameo. In: 18th USENIX Symposium on Networked Systems Design and Implementation (NSDI 21), pp.\u00a0389\u2013405. USENIX Association (2021)"},{"key":"3758_CR6","doi-asserted-by":"crossref","unstructured":"Zaharia, M.,\u00a0Das, T.,\u00a0Li, H.,\u00a0Hunter, T.,\u00a0Shenker, S., Stoica, I.: Discretized streams: fault-tolerant streaming computation at scale. In: Proceedings of the Twenty-Fourth ACM Symposium on Operating Systems Principles, pp.\u00a0423\u2013438 (2013)","DOI":"10.1145\/2517349.2522737"},{"key":"3758_CR7","doi-asserted-by":"crossref","unstructured":"Armbrust, M.,\u00a0Das, T.,\u00a0Torres, J.,\u00a0Yavuz, B.,\u00a0Zhu, S.,\u00a0Xin, R.,\u00a0Ghodsi, A.,\u00a0Stoica, I.,\u00a0Zaharia, M.: Structured streaming: a declarative API for real-time applications in Apache Spark. In: Proceedings of the 2018 International Conference on Management of Data, pp.\u00a0601\u2013613 (2018)","DOI":"10.1145\/3183713.3190664"},{"key":"3758_CR8","doi-asserted-by":"crossref","unstructured":"Akidau, T.,\u00a0Bradshaw, R.,\u00a0Chambers, C.,\u00a0Chernyak, S., Fern\u00e1ndez-Moctezuma, R.\u00a0J., Lax, R.,\u00a0McVeety, S.,\u00a0Mills, D.,\u00a0Perry, F.,\u00a0Schmidt, E.,\u00a0Whittle, S.: The dataflow model: a practical approach to balancing correctness, latency, and cost in massive-scale, unbounded, out-of-order data processing. In: Proceedings of the VLDB Endowment, vol.\u00a08, pp.\u00a01792\u20131803 (2015)","DOI":"10.14778\/2824032.2824076"},{"key":"3758_CR9","doi-asserted-by":"crossref","unstructured":"Chen, F.,\u00a0Wu, S.,\u00a0Jin, H.,\u00a0Yao, Y.,\u00a0Liu, Z.,\u00a0Gu, L.,\u00a0Zhou, Y.: Lever: towards low-latency batched stream processing by pre-scheduling. In: Proceedings of the 2017 Symposium on Cloud Computing, SoCC \u201917, (New York, NY, USA), p.\u00a0643. Association for Computing Machinery (2017)","DOI":"10.1145\/3127479.3132687"},{"key":"3758_CR10","doi-asserted-by":"crossref","unstructured":"He, B.,\u00a0Yang, M.,\u00a0Guo, Z.,\u00a0Chen, R.,\u00a0Su, B.,\u00a0Lin, W.,\u00a0Zhou, L.: Comet: batched stream processing for data intensive distributed computing. In: Proceedings of the 1st ACM Symposium on Cloud Computing, SoCC \u201910, (New York, NY, USA), pp.\u00a063\u201374. Association for Computing Machinery (2010)","DOI":"10.1145\/1807128.1807139"},{"issue":"11","key":"3758_CR11","doi-asserted-by":"publisher","first-page":"56","DOI":"10.1145\/2934664","volume":"59","author":"M Zaharia","year":"2016","unstructured":"Zaharia, M., Xin, R.S., Wendell, P., Das, T., Armbrust, M., Dave, A., Meng, X., Rosen, J., Venkataraman, S., Franklin, M.J., et al.: Apache Spark: a unified engine for big data processing. Commun. ACM 59(11), 56\u201365 (2016)","journal-title":"Commun. ACM"},{"key":"3758_CR12","unstructured":"Zaharia, M.,\u00a0Chowdhury, M.,\u00a0Das, T.,\u00a0Dave, A.,\u00a0Ma, J.,\u00a0McCauly, M., Franklin, M.\u00a0J.,\u00a0Shenker, S.,\u00a0Stoica, I.: Resilient distributed datasets: a fault-tolerant abstraction for in-memory cluster computing. In: 9th USENIX Symposium on Networked Systems Design and Implementation (NSDI 12), (San Jose, CA), pp.\u00a015\u201328. USENIX Association (2012)"},{"key":"3758_CR13","first-page":"1","volume":"11","author":"J Kreps","year":"2011","unstructured":"Kreps, J., Narkhede, N., Rao, J., et al.: Kafka: a distributed messaging system for log processing. Proc. NetDB 11, 1\u20137 (2011)","journal-title":"Proc. NetDB"},{"key":"3758_CR14","doi-asserted-by":"crossref","unstructured":"Arasu, A., Cherniack, M., Galvez, E., Maier, D., Maskey, A.S., Ryvkina, E., Stonebraker, M., Tibbetts, R.: Linear road: a stream data management benchmark. In: Proceedings of the Thirtieth International Conference on Very Large Data Bases-Volume 30, pp. 480\u2013491 (2004)","DOI":"10.1016\/B978-012088469-8\/50044-9"},{"key":"3758_CR15","doi-asserted-by":"crossref","unstructured":"Koliousis, A.,\u00a0Weidlich, M.,\u00a0Castro\u00a0Fernandez, R., Wolf, A.\u00a0L.,\u00a0Costa, P.,\u00a0Pietzuch, P.: Saber: window-based hybrid stream processing for heterogeneous architectures. In: Proceedings of the 2016 International Conference on Management of Data, pp.\u00a0555\u2013569 (2016)","DOI":"10.1145\/2882903.2882906"},{"key":"3758_CR16","doi-asserted-by":"crossref","unstructured":"Das, T.,\u00a0Zhong, Y.,\u00a0Stoica, I.,\u00a0Shenker, S.: Adaptive stream processing using dynamic batch sizing. In: Proceedings of the ACM Symposium on Cloud Computing. SOCC \u201914, Seattle, WA, pp.\u00a01\u201313. Association for Computing Machinery, New York, NY (2014)","DOI":"10.1145\/2670979.2670995"},{"issue":"12","key":"3758_CR17","doi-asserted-by":"publisher","first-page":"2672","DOI":"10.1109\/TPDS.2018.2846234","volume":"29","author":"D Cheng","year":"2018","unstructured":"Cheng, D., Zhou, X., Wang, Y., Jiang, C.: Adaptive scheduling parallel jobs with dynamic batching in spark streaming. IEEE Trans. Parallel Distrib. Syst. 29(12), 2672\u20132685 (2018)","journal-title":"IEEE Trans. Parallel Distrib. Syst."},{"key":"3758_CR18","doi-asserted-by":"crossref","unstructured":"Garefalakis, P.,\u00a0Karanasos, K.,\u00a0Pietzuch, P.: Neptune: scheduling suspendable tasks for unified stream\/batch applications. In: Proceedings of the ACM Symposium on Cloud Computing (SoCC), pp.\u00a0233\u2013245 (2019)","DOI":"10.1145\/3357223.3362724"}],"container-title":["Cluster Computing"],"original-title":[],"language":"en","link":[{"URL":"https:\/\/link.springer.com\/content\/pdf\/10.1007\/s10586-022-03758-1.pdf","content-type":"application\/pdf","content-version":"vor","intended-application":"text-mining"},{"URL":"https:\/\/link.springer.com\/article\/10.1007\/s10586-022-03758-1\/fulltext.html","content-type":"text\/html","content-version":"vor","intended-application":"text-mining"},{"URL":"https:\/\/link.springer.com\/content\/pdf\/10.1007\/s10586-022-03758-1.pdf","content-type":"application\/pdf","content-version":"vor","intended-application":"similarity-checking"}],"deposited":{"date-parts":[[2023,8,26]],"date-time":"2023-08-26T20:23:45Z","timestamp":1693081425000},"score":1,"resource":{"primary":{"URL":"https:\/\/link.springer.com\/10.1007\/s10586-022-03758-1"}},"subtitle":[],"short-title":[],"issued":{"date-parts":[[2022,10,14]]},"references-count":18,"journal-issue":{"issue":"5","published-print":{"date-parts":[[2023,10]]}},"alternative-id":["3758"],"URL":"https:\/\/doi.org\/10.1007\/s10586-022-03758-1","relation":{},"ISSN":["1386-7857","1573-7543"],"issn-type":[{"type":"print","value":"1386-7857"},{"type":"electronic","value":"1573-7543"}],"subject":[],"published":{"date-parts":[[2022,10,14]]},"assertion":[{"value":"19 April 2022","order":1,"name":"received","label":"Received","group":{"name":"ArticleHistory","label":"Article History"}},{"value":"29 July 2022","order":2,"name":"revised","label":"Revised","group":{"name":"ArticleHistory","label":"Article History"}},{"value":"18 September 2022","order":3,"name":"accepted","label":"Accepted","group":{"name":"ArticleHistory","label":"Article History"}},{"value":"14 October 2022","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 have no relevant financial or non-financial interests to disclose.","order":2,"name":"Ethics","group":{"name":"EthicsHeading","label":"Competing interests"}}]}}