{"status":"ok","message-type":"work","message-version":"1.0.0","message":{"indexed":{"date-parts":[[2025,2,21]],"date-time":"2025-02-21T07:38:56Z","timestamp":1740123536524,"version":"3.37.3"},"reference-count":29,"publisher":"Springer Science and Business Media LLC","issue":"11","license":[{"start":{"date-parts":[[2016,6,22]],"date-time":"2016-06-22T00:00:00Z","timestamp":1466553600000},"content-version":"tdm","delay-in-days":0,"URL":"http:\/\/www.springer.com\/tdm"}],"funder":[{"DOI":"10.13039\/501100000781","name":"European Research Council","doi-asserted-by":"publisher","award":["ICT-609666"],"award-info":[{"award-number":["ICT-609666"]}],"id":[{"id":"10.13039\/501100000781","id-type":"DOI","asserted-by":"publisher"}]}],"content-domain":{"domain":["link.springer.com"],"crossmark-restriction":false},"short-container-title":["J Supercomput"],"published-print":{"date-parts":[[2018,11]]},"DOI":"10.1007\/s11227-016-1793-9","type":"journal-article","created":{"date-parts":[[2016,6,23]],"date-time":"2016-06-23T01:14:18Z","timestamp":1466644458000},"page":"5659-5673","update-policy":"https:\/\/doi.org\/10.1007\/springer_crossmark_policy","source":"Crossref","is-referenced-by-count":8,"title":["Data stream processing via code annotations"],"prefix":"10.1007","volume":"74","author":[{"given":"Marco","family":"Danelutto","sequence":"first","affiliation":[],"role":[{"role":"author","vocabulary":"crossref"}]},{"given":"Tiziano","family":"De Matteis","sequence":"additional","affiliation":[],"role":[{"role":"author","vocabulary":"crossref"}]},{"given":"Gabriele","family":"Mencagli","sequence":"additional","affiliation":[],"role":[{"role":"author","vocabulary":"crossref"}]},{"given":"Massimo","family":"Torquati","sequence":"additional","affiliation":[],"role":[{"role":"author","vocabulary":"crossref"}]}],"member":"297","published-online":{"date-parts":[[2016,6,22]]},"reference":[{"key":"1793_CR1","doi-asserted-by":"crossref","DOI":"10.1017\/CBO9781139058940","volume-title":"Fundamentals of stream processing","author":"H Andrade","year":"2014","unstructured":"Andrade H, Gedik B, Turaga D (2014) Fundamentals of stream processing. Cambridge University Press, Cambridge"},{"key":"1793_CR2","doi-asserted-by":"crossref","unstructured":"Cugola G, Margara A (2012) Processing flows of information: From data stream to complex event processing. ACM Comput Surv 44(3):15:1\u201315:62","DOI":"10.1145\/2187671.2187677"},{"key":"1793_CR3","doi-asserted-by":"crossref","unstructured":"Castro Fernandez R, Migliavacca M, Kalyvianaki E, Pietzuch P (2013) Integrating scale out and fault tolerance in stream processing using operator state management. In: Proc. of the 2013 ACM SIGMOD international conference on management of data, SIGMOD \u201913. ACM, New York, pp 725\u2013736","DOI":"10.1145\/2463676.2465282"},{"key":"1793_CR4","volume-title":"Using OpenMP: portable shared memory parallel programming (scientific and engineering computation)","author":"B Chapman","year":"2007","unstructured":"Chapman B, Jost G, Pas Rvd (2007) Using OpenMP: portable shared memory parallel programming (scientific and engineering computation). The MIT Press, USA"},{"key":"1793_CR5","doi-asserted-by":"crossref","unstructured":"Danelutto M, De Matteis T., Mencagli G, Torquati M (2015) Parallelizing high-frequency trading applications by using c++11 attributes. In: Proc. of the 1st IEEE Inter. workshop on reengineering for parallelism in heterogeneous parallel platforms","DOI":"10.1109\/Trustcom.2015.623"},{"key":"1793_CR6","doi-asserted-by":"crossref","unstructured":"Danelutto M, Garcia JD, Sanchez LM, Sotomayor R, Torquati, M (2016) Introducing parallelism by using repara c++11 attributes. In: Proc. of the 17th Euromicro PDP 2016: parallel distributed and network-based processing. IEEE, Crete","DOI":"10.1109\/PDP.2016.115"},{"key":"1793_CR7","doi-asserted-by":"crossref","unstructured":"Danelutto M, Torquati M (2015) Structured parallel programming with \u201ccore\u201d fastflow. In: Zs\u00f3k V, Horv\u00e1th Z, Csat\u00f3 L (eds) Central European functional programming school. vol 8606, Springer, LNCS, pp 29\u201375","DOI":"10.1007\/978-3-319-15940-9_2"},{"key":"1793_CR8","doi-asserted-by":"crossref","unstructured":"De Matteis T, Mencagli G (2016) Keep calm and react with foresight: strategies for low- latency and energy-efficient elastic data stream processing. In: Proceedings of the 21th ACM SIGPLAN symposium on principles and practice of parallel programming, PPoPP 2016. ACM, New York","DOI":"10.1145\/2851141.2851148"},{"key":"1793_CR9","unstructured":"Enterprise C, Inc. (2011) C, NVIDIA, the Portland\u00a0Group: The OpenACC Application Programming Interface, v1.0a"},{"key":"1793_CR10","unstructured":"FastFlow website (2015). http:\/\/mc-fastflow.sourceforge.net\/"},{"issue":"12","key":"1793_CR11","doi-asserted-by":"crossref","first-page":"2351","DOI":"10.1109\/TPDS.2012.24","volume":"23","author":"V Gulisano","year":"2012","unstructured":"Gulisano V, Jimenez-Peris R, Patino-Martinez M, Soriente C, Valduriez P (2012) Streamcloud: An elastic and scalable data streaming system. IEEE Trans Parallel Distrib Syst 23(12):2351\u20132365","journal-title":"IEEE Trans Parallel Distrib Syst"},{"key":"1793_CR12","unstructured":"IBM Infosphere Streams website (2015). http:\/\/www-03.ibm.com\/software\/products\/en\/ibm-streams"},{"key":"1793_CR13","unstructured":"Apache Spark Streaming website (2015). https:\/\/spark.apache.org\/streaming"},{"key":"1793_CR14","unstructured":"Apache Storm website (2015). https:\/\/storm.apache.org"},{"key":"1793_CR15","unstructured":"Intel $$\\textregistered $$ \u00ae TBB website (2015). http:\/\/threadingbuildingblocks.org"},{"key":"1793_CR16","doi-asserted-by":"crossref","unstructured":"Leijen D, Schulte W, Burckhardt S (2009) The design of a task parallel library. In: Proc. of the 24th ACM SIGPLAN conference on object oriented programming systems languages and applications, OOPSLA \u201909, ACM, New York, pp 227\u2013242","DOI":"10.1145\/1640089.1640106"},{"issue":"8","key":"1793_CR17","doi-asserted-by":"crossref","first-page":"207","DOI":"10.1145\/209937.209958","volume":"30","author":"RD Blumofe","year":"1995","unstructured":"Blumofe RD, Joerg CF, Kuszmaul BC, Leiserson CE, Randall KH, Zhou Y (1995) Cilk: an efficient multithreaded runtime system. SIGPLAN Not 30(8):207\u2013216","journal-title":"SIGPLAN Not"},{"key":"1793_CR18","unstructured":"Kramer P, Egloff D, Blaser L (2016) The alea reactive dataflow system for gpu parallelization. In: Proc. of the HLGPU 2016 Workshop, HiPEAC 2016, Prague"},{"key":"1793_CR19","unstructured":"REPARA website (2016). http:\/\/repara-project.eu\/"},{"key":"1793_CR20","unstructured":"ISO\/IEC (2011) Information technology\u2014Programming languages\u2014C++. International Standard ISO\/IEC 14882:20111, ISO\/IEC, Geneva"},{"key":"1793_CR21","unstructured":"REPARA Project Deliverable, \u201cD2.1: REPARA C++ Open Specification document\u201d (2015)"},{"issue":"2","key":"1793_CR22","doi-asserted-by":"crossref","first-page":"145","DOI":"10.1016\/j.jpdc.2010.08.007","volume":"71","author":"H Andrade","year":"2011","unstructured":"Andrade H, Gedik B, Wu KL, Yu PS (2011) Processing high data rate streams in system s. J Parallel Distrib Comput 71(2):145\u2013156","journal-title":"J Parallel Distrib Comput"},{"key":"1793_CR23","doi-asserted-by":"crossref","unstructured":"Babcock B, Babu S, Datar M, Motwani R, Widom J (2002) Models and issues in data stream systems. In: Proc. of the 21st ACM SIGMOD-SIGACT-SIGART Symp. on principles of database systems, PODS \u201902, ACM, New York, pp 1\u201316","DOI":"10.1145\/543613.543615"},{"issue":"6","key":"1793_CR24","doi-asserted-by":"crossref","first-page":"1012","DOI":"10.1007\/s10766-013-0273-6","volume":"42","author":"M Aldinucci","year":"2014","unstructured":"Aldinucci M, Campa S, Danelutto M, Kilpatrick P, Torquati M (2014) Design patterns percolating to parallel programming framework implementation. Int J Parallel Program 42(6):1012\u20131031","journal-title":"Int J Parallel Program"},{"key":"1793_CR25","unstructured":"Balkesen C, Tatbul N (2011) Scalable data partitioning techniques for parallel sliding window processing over data streams. In: VLDB Inter. workshop on data management for sensor networks (DMSN\u201911), Seattle"},{"key":"1793_CR26","unstructured":"Mattson T, Sanders B, Massingill B (2004) Patterns for parallel programming, 1st edn. Addison-Wesley Professional, USA"},{"key":"1793_CR27","doi-asserted-by":"crossref","unstructured":"Thies W, Karczmarek M, Amarasinghe SP (2002) Streamit: a language for streaming applications. In: Proc. of the 11th Inter. conference on compiler construction, CC \u201902. Springer-Verlag, London, pp 179\u2013196","DOI":"10.1007\/3-540-45937-5_14"},{"key":"1793_CR28","unstructured":"REPARA Project Deliverable, \u201cD2.2: Static analysis techniques for AIR generation\u201d. Available at: http:\/\/repara-project.eu\/"},{"key":"1793_CR29","unstructured":"REPARA Project Deliverable, \u201cD3.3: Static partitioning tool\u201d (2015)"}],"container-title":["The Journal of Supercomputing"],"original-title":[],"language":"en","link":[{"URL":"http:\/\/link.springer.com\/article\/10.1007\/s11227-016-1793-9\/fulltext.html","content-type":"text\/html","content-version":"vor","intended-application":"text-mining"},{"URL":"http:\/\/link.springer.com\/content\/pdf\/10.1007\/s11227-016-1793-9.pdf","content-type":"application\/pdf","content-version":"vor","intended-application":"text-mining"},{"URL":"http:\/\/link.springer.com\/content\/pdf\/10.1007\/s11227-016-1793-9","content-type":"unspecified","content-version":"vor","intended-application":"similarity-checking"},{"URL":"http:\/\/link.springer.com\/content\/pdf\/10.1007\/s11227-016-1793-9.pdf","content-type":"application\/pdf","content-version":"vor","intended-application":"similarity-checking"}],"deposited":{"date-parts":[[2019,9,9]],"date-time":"2019-09-09T22:28:25Z","timestamp":1568068105000},"score":1,"resource":{"primary":{"URL":"http:\/\/link.springer.com\/10.1007\/s11227-016-1793-9"}},"subtitle":[],"short-title":[],"issued":{"date-parts":[[2016,6,22]]},"references-count":29,"journal-issue":{"issue":"11","published-print":{"date-parts":[[2018,11]]}},"alternative-id":["1793"],"URL":"https:\/\/doi.org\/10.1007\/s11227-016-1793-9","relation":{},"ISSN":["0920-8542","1573-0484"],"issn-type":[{"type":"print","value":"0920-8542"},{"type":"electronic","value":"1573-0484"}],"subject":[],"published":{"date-parts":[[2016,6,22]]}}}