{"status":"ok","message-type":"work","message-version":"1.0.0","message":{"indexed":{"date-parts":[[2026,3,10]],"date-time":"2026-03-10T15:18:29Z","timestamp":1773155909508,"version":"3.50.1"},"reference-count":22,"publisher":"Springer Science and Business Media LLC","issue":"5","license":[{"start":{"date-parts":[[2021,3,18]],"date-time":"2021-03-18T00:00:00Z","timestamp":1616025600000},"content-version":"tdm","delay-in-days":0,"URL":"https:\/\/www.springer.com\/tdm"},{"start":{"date-parts":[[2021,3,18]],"date-time":"2021-03-18T00:00:00Z","timestamp":1616025600000},"content-version":"vor","delay-in-days":0,"URL":"https:\/\/www.springer.com\/tdm"}],"funder":[{"name":"National Key Research and Development Program of China","award":["2017YFB0202002"],"award-info":[{"award-number":["2017YFB0202002"]}]}],"content-domain":{"domain":["link.springer.com"],"crossmark-restriction":false},"short-container-title":["Int J Parallel Prog"],"published-print":{"date-parts":[[2021,10]]},"DOI":"10.1007\/s10766-021-00696-0","type":"journal-article","created":{"date-parts":[[2021,3,18]],"date-time":"2021-03-18T18:47:37Z","timestamp":1616093257000},"page":"671-684","update-policy":"https:\/\/doi.org\/10.1007\/springer_crossmark_policy","source":"Crossref","is-referenced-by-count":11,"title":["RDMA-Based Apache Storm for High-Performance Stream Data Processing"],"prefix":"10.1007","volume":"49","author":[{"ORCID":"https:\/\/orcid.org\/0000-0001-6293-7227","authenticated-orcid":false,"given":"Ziyu","family":"Zhang","sequence":"first","affiliation":[],"role":[{"role":"author","vocabulary":"crossref"}]},{"given":"Zitan","family":"Liu","sequence":"additional","affiliation":[],"role":[{"role":"author","vocabulary":"crossref"}]},{"given":"Qingcai","family":"Jiang","sequence":"additional","affiliation":[],"role":[{"role":"author","vocabulary":"crossref"}]},{"given":"Junshi","family":"Chen","sequence":"additional","affiliation":[],"role":[{"role":"author","vocabulary":"crossref"}]},{"given":"Hong","family":"An","sequence":"additional","affiliation":[],"role":[{"role":"author","vocabulary":"crossref"}]}],"member":"297","published-online":{"date-parts":[[2021,3,18]]},"reference":[{"issue":"2","key":"696_CR1","doi-asserted-by":"publisher","first-page":"120","DOI":"10.1007\/s00778-003-0095-z","volume":"12","author":"DJ Abadi","year":"2003","unstructured":"Abadi, D.J., Carney, D., \u00c7etintemel, U., Cherniack, M., Convey, C., Lee, S., Stonebraker, M., Tatbul, N., Zdonik, S.B.: Aurora: a new model and architecture for data stream management. VLDB J. 12(2), 120\u2013139 (2003). https:\/\/doi.org\/10.1007\/s00778-003-0095-z","journal-title":"VLDB J."},{"key":"696_CR2","doi-asserted-by":"publisher","first-page":"28","DOI":"10.1016\/j.jpdc.2017.12.007","volume":"114","author":"E Agostini","year":"2018","unstructured":"Agostini, E., Rossetti, D., Potluri, S.: Gpudirect async: exploring GPU synchronous communication techniques for infiniband clusters. J. Parallel Distrib. Comput. 114, 28\u201345 (2018). https:\/\/doi.org\/10.1016\/j.jpdc.2017.12.007","journal-title":"J. Parallel Distrib. Comput."},{"issue":"12","key":"696_CR3","doi-asserted-by":"publisher","first-page":"1792","DOI":"10.14778\/2824032.2824076","volume":"8","author":"T Akidau","year":"2015","unstructured":"Akidau, T., Bradshaw, R., Chambers, C., Chernyak, S., Fern\u00e1ndez-Moctezuma, R., Lax, R., McVeety, S., Mills, D., Perry, F., Schmidt, E., Whittle, S.: 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","journal-title":"Proc. VLDB Endow."},{"key":"696_CR4","doi-asserted-by":"publisher","first-page":"401","DOI":"10.1016\/j.future.2019.11.014","volume":"111","author":"G Amarasinghe","year":"2020","unstructured":"Amarasinghe, G., de Assun\u00e7\u00e3o, M.D., Harwood, A., Karunasekera, S.: Ecsnet++: a simulator for distributed stream processing on edge and cloud environments. Future Gener. Comput. Syst. 111, 401\u2013418 (2020). https:\/\/doi.org\/10.1016\/j.future.2019.11.014","journal-title":"Future Gener. Comput. Syst."},{"key":"696_CR5","doi-asserted-by":"publisher","DOI":"10.1016\/j.csi.2020.103426","author":"D Corral-Plaza","year":"2020","unstructured":"Corral-Plaza, D., Medina-Bulo, I., Ortiz, G., Boubeta-Puig, J.: A stream processing architecture for heterogeneous data sources in the internet of things. Comput. Stand. Interfaces (2020). https:\/\/doi.org\/10.1016\/j.csi.2020.103426","journal-title":"Comput. Stand. Interfaces"},{"key":"696_CR6","doi-asserted-by":"publisher","unstructured":"Evans, R.: Apache storm, a hands on tutorial. In: 2015 IEEE International Conference on Cloud Engineering, IC2E 2015, Tempe, AZ, USA, March 9\u201313, 2015, p.\u00a02. IEEE Computer Society (2015). https:\/\/doi.org\/10.1109\/IC2E.2015.67","DOI":"10.1109\/IC2E.2015.67"},{"key":"696_CR7","volume-title":"Introduction to Apache Flink: Stream Processing for Real Time and Beyond","author":"E Friedman","year":"2016","unstructured":"Friedman, E., Tzoumas, K.: Introduction to Apache Flink: Stream Processing for Real Time and Beyond, 1st edn. O\u2019Reilly Media, Inc., Newton (2016)","edition":"1"},{"key":"696_CR8","doi-asserted-by":"publisher","unstructured":"He, Z., Wang, D., Fu, B., Tan, K., Hua, B., Zhang, Z.L., Zheng, K.: MASQ: RDMA for virtual private cloud. In: Proceedings of the Annual Conference of the ACM Special Interest Group on Data Communication on the Applications, Technologies, Architectures, and Protocols for Computer Communication, SIGCOMM \u201920, p. 1\u201314. Association for Computing Machinery, New York, NY, USA (2020). https:\/\/doi.org\/10.1145\/3387514.3405849","DOI":"10.1145\/3387514.3405849"},{"issue":"4","key":"696_CR9","doi-asserted-by":"publisher","first-page":"674","DOI":"10.1007\/s10766-017-0520-3","volume":"46","author":"C Jia","year":"2018","unstructured":"Jia, C., Liu, J., Jin, X., Lin, H., An, H., Han, W., Wu, Z., Chi, M.: Improving the performance of distributed tensorflow with RDMA. Int. J. Parallel Program. 46(4), 674\u2013685 (2018). https:\/\/doi.org\/10.1007\/s10766-017-0520-3","journal-title":"Int. J. Parallel Program."},{"issue":"3","key":"696_CR10","doi-asserted-by":"publisher","first-page":"50:1","DOI":"10.1145\/3355399","volume":"53","author":"X Liu","year":"2020","unstructured":"Liu, X., Buyya, R.: Resource management and scheduling in distributed stream processing systems: a taxonomy, review, and future directions. ACM Comput. Surv. 53(3), 50:1-50:41 (2020). https:\/\/doi.org\/10.1145\/3355399","journal-title":"ACM Comput. Surv."},{"key":"696_CR11","doi-asserted-by":"publisher","unstructured":"Lu, F., Fang, T., Zhang, Z., Li, S., Chen, J., An, H., Han, W.: Improving the performance of mongodb with RDMA. In: Z.\u00a0Xiao, L.T. Yang, P.\u00a0Balaji, T.\u00a0Li, K.\u00a0Li, A.Y. Zomaya (eds.) 21st IEEE International Conference on High Performance Computing and Communications; 17th IEEE International Conference on Smart City; 5th IEEE International Conference on Data Science and Systems, HPCC\/SmartCity\/DSS 2019, Zhangjiajie, China, August 10-12, 2019, pp. 1004\u20131010. IEEE (2019). https:\/\/doi.org\/10.1109\/HPCC\/SmartCity\/DSS.2019.00144","DOI":"10.1109\/HPCC\/SmartCity\/DSS.2019.00144"},{"issue":"4","key":"696_CR12","doi-asserted-by":"publisher","first-page":"2894","DOI":"10.1109\/COMST.2017.2746083","volume":"19","author":"P MacArthur","year":"2017","unstructured":"MacArthur, P., Liu, Q., Russell, R.D., Mizero, F., Veeraraghavan, M., Dennis, J.M.: An integrated tutorial on infiniband, verbs, and MPI. IEEE Commun. Surv. Tutor. 19(4), 2894\u20132926 (2017). https:\/\/doi.org\/10.1109\/COMST.2017.2746083","journal-title":"IEEE Commun. Surv. Tutor."},{"key":"696_CR13","unstructured":"Ousterhout, K., Rasti, R., Ratnasamy, S., Shenker, S., Chun, B.: Making sense of performance in data analytics frameworks. In: 12th USENIX Symposium on Networked Systems Design and Implementation, NSDI 15, Oakland, CA, USA, May 4\u20136, 2015, pp. 293\u2013307. USENIX Association (2015). https:\/\/www.usenix.org\/conference\/nsdi15\/technical-sessions\/presentation\/ousterhout"},{"key":"696_CR14","doi-asserted-by":"publisher","unstructured":"Stuedi, P., Metzler, B., Trivedi, A.: jVerbs: Ultra-low latency for data center applications. In: Proceedings of the 4th Annual Symposium on Cloud Computing, SoCC 2013 (2013). https:\/\/doi.org\/10.1145\/2523616.2523631","DOI":"10.1145\/2523616.2523631"},{"issue":"1","key":"696_CR15","doi-asserted-by":"publisher","first-page":"52","DOI":"10.1504\/IJBIC.2020.105892","volume":"15","author":"D Sun","year":"2020","unstructured":"Sun, D., Gao, S., Liu, X., Li, F., Buyya, R.: Performance-aware deployment of streaming applications in distributed stream computing systems. Int. J. Bio Inspired Comput. 15(1), 52\u201362 (2020). https:\/\/doi.org\/10.1504\/IJBIC.2020.105892","journal-title":"Int. J. Bio Inspired Comput."},{"key":"696_CR16","unstructured":"Trivedi, A., Stuedi, P., Pfefferle, J., Stoica, R., Metzler, B., Koltsidas, I., Ioannou, N.: On the [ir]relevance of network performance for data processing. In: A.\u00a0Clements, T.\u00a0Condie (eds.) 8th USENIX Workshop on Hot Topics in Cloud Computing, HotCloud 2016, Denver, CO, USA, June 20\u201321, 2016. USENIX Association (2016). https:\/\/www.usenix.org\/conference\/hotcloud16\/workshop-program\/presentation\/trivedi"},{"key":"696_CR17","doi-asserted-by":"publisher","first-page":"156915","DOI":"10.1109\/ACCESS.2020.3019302","volume":"8","author":"Z Wu","year":"2020","unstructured":"Wu, Z., Li, M., Chi, M., Xu, L., An, H.: Runtime adaptive matrix multiplication for the SW26010 many-core processor. IEEE Access 8, 156915\u2013156928 (2020). https:\/\/doi.org\/10.1109\/ACCESS.2020.3019302","journal-title":"IEEE Access"},{"issue":"10","key":"696_CR18","doi-asserted-by":"publisher","first-page":"6804","DOI":"10.1007\/s11227-019-02905-7","volume":"75","author":"S Yang","year":"2019","unstructured":"Yang, S., Son, S., Choi, M., Moon, Y.: Performance improvement of apache storm using infiniband RDMA. J. Supercomput. 75(10), 6804\u20136830 (2019). https:\/\/doi.org\/10.1007\/s11227-019-02905-7","journal-title":"J. Supercomput."},{"issue":"11","key":"696_CR19","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., Ghodsi, A., Gonzalez, J., Shenker, S., Stoica, I.: Apache spark: a unified engine for big data processing. Commun. ACM 59(11), 56\u201365 (2016). https:\/\/doi.org\/10.1145\/2934664","journal-title":"Commun. ACM"},{"issue":"5","key":"696_CR20","doi-asserted-by":"publisher","first-page":"516","DOI":"10.14778\/3303753.3303758","volume":"12","author":"S Zeuch","year":"2019","unstructured":"Zeuch, S., Bre\u00df, S., Rabl, T., Monte, B.D., Karimov, J., Lutz, C., Renz, M., Traub, J., Markl, V.: Analyzing efficient stream processing on modern hardware. Proc. VLDB Endow. 12(5), 516\u2013530 (2019). https:\/\/doi.org\/10.14778\/3303753.3303758","journal-title":"Proc. VLDB Endow."},{"key":"696_CR21","doi-asserted-by":"publisher","unstructured":"Zhang, S., He, B., Dahlmeier, D., Zhou, A.C., Heinze, T.: Revisiting the design of data stream processing systems on multi-core processors. In: 33rd IEEE International Conference on Data Engineering, ICDE 2017, San Diego, CA, USA, April 19\u201322, 2017, pp. 659\u2013670. IEEE Computer Society (2017). https:\/\/doi.org\/10.1109\/ICDE.2017.119","DOI":"10.1109\/ICDE.2017.119"},{"key":"696_CR22","doi-asserted-by":"publisher","unstructured":"Zhang, S., He, J., Zhou, A.C., He, B.: Briskstream: Scaling data stream processing on shared-memory multicore architectures. In: P.A. Boncz, S.\u00a0Manegold, A.\u00a0Ailamaki, A.\u00a0Deshpande, T.\u00a0Kraska (eds.) Proceedings of the 2019 International Conference on Management of Data, SIGMOD Conference 2019, Amsterdam, The Netherlands, June 30\u2013July 5, 2019, pp. 705\u2013722. ACM (2019). https:\/\/doi.org\/10.1145\/3299869.3300067","DOI":"10.1145\/3299869.3300067"}],"container-title":["International Journal of Parallel Programming"],"original-title":[],"language":"en","link":[{"URL":"https:\/\/link.springer.com\/content\/pdf\/10.1007\/s10766-021-00696-0.pdf","content-type":"application\/pdf","content-version":"vor","intended-application":"text-mining"},{"URL":"https:\/\/link.springer.com\/article\/10.1007\/s10766-021-00696-0\/fulltext.html","content-type":"text\/html","content-version":"vor","intended-application":"text-mining"},{"URL":"https:\/\/link.springer.com\/content\/pdf\/10.1007\/s10766-021-00696-0.pdf","content-type":"application\/pdf","content-version":"vor","intended-application":"similarity-checking"}],"deposited":{"date-parts":[[2021,8,24]],"date-time":"2021-08-24T21:06:42Z","timestamp":1629839202000},"score":1,"resource":{"primary":{"URL":"https:\/\/link.springer.com\/10.1007\/s10766-021-00696-0"}},"subtitle":[],"short-title":[],"issued":{"date-parts":[[2021,3,18]]},"references-count":22,"journal-issue":{"issue":"5","published-print":{"date-parts":[[2021,10]]}},"alternative-id":["696"],"URL":"https:\/\/doi.org\/10.1007\/s10766-021-00696-0","relation":{},"ISSN":["0885-7458","1573-7640"],"issn-type":[{"value":"0885-7458","type":"print"},{"value":"1573-7640","type":"electronic"}],"subject":[],"published":{"date-parts":[[2021,3,18]]},"assertion":[{"value":"13 November 2020","order":1,"name":"received","label":"Received","group":{"name":"ArticleHistory","label":"Article History"}},{"value":"27 February 2021","order":2,"name":"accepted","label":"Accepted","group":{"name":"ArticleHistory","label":"Article History"}},{"value":"18 March 2021","order":3,"name":"first_online","label":"First Online","group":{"name":"ArticleHistory","label":"Article History"}}]}}