{"status":"ok","message-type":"work","message-version":"1.0.0","message":{"indexed":{"date-parts":[[2026,3,12]],"date-time":"2026-03-12T07:10:07Z","timestamp":1773299407559,"version":"3.50.1"},"reference-count":22,"publisher":"Springer Science and Business Media LLC","issue":"2","license":[{"start":{"date-parts":[[2016,3,25]],"date-time":"2016-03-25T00:00:00Z","timestamp":1458864000000},"content-version":"tdm","delay-in-days":0,"URL":"http:\/\/www.springer.com\/tdm"}],"funder":[{"name":"EU H2020 RePhrase"}],"content-domain":{"domain":["link.springer.com"],"crossmark-restriction":false},"short-container-title":["Int J Parallel Prog"],"published-print":{"date-parts":[[2017,4]]},"DOI":"10.1007\/s10766-016-0413-x","type":"journal-article","created":{"date-parts":[[2016,3,25]],"date-time":"2016-03-25T06:32:39Z","timestamp":1458887559000},"page":"382-401","update-policy":"https:\/\/doi.org\/10.1007\/springer_crossmark_policy","source":"Crossref","is-referenced-by-count":28,"title":["Parallel Patterns for Window-Based Stateful Operators on Data Streams: An Algorithmic Skeleton Approach"],"prefix":"10.1007","volume":"45","author":[{"given":"Tiziano","family":"De Matteis","sequence":"first","affiliation":[],"role":[{"role":"author","vocabulary":"crossref"}]},{"ORCID":"https:\/\/orcid.org\/0000-0002-6263-7723","authenticated-orcid":false,"given":"Gabriele","family":"Mencagli","sequence":"additional","affiliation":[],"role":[{"role":"author","vocabulary":"crossref"}]}],"member":"297","published-online":{"date-parts":[[2016,3,25]]},"reference":[{"issue":"3","key":"413_CR1","doi-asserted-by":"crossref","first-page":"15:1","DOI":"10.1145\/2187671.2187677","volume":"44","author":"G Cugola","year":"2012","unstructured":"Cugola, G., Margara, A.: Processing flows of information: from data stream to complex event processing. ACM Comput. Surv. 44(3), 15:1\u201315:62 (2012)","journal-title":"ACM Comput. Surv."},{"key":"413_CR2","unstructured":"Apache spark streaming. https:\/\/spark.apache.org\/streaming"},{"key":"413_CR3","unstructured":"Apache storm. https:\/\/storm.apache.org"},{"key":"413_CR4","unstructured":"Ibm infosphere streams. http:\/\/www-03.ibm.com\/software\/products\/en\/infosphere-streams"},{"key":"413_CR5","doi-asserted-by":"crossref","unstructured":"Babcock, B., Babu, S., Datar, M., Motwani, R., Widom, J.: Models and issues in data stream systems. In: Proceedings of the twenty-first ACM SIGMOD-SIGACT-SIGART Symposium on Principles of Database Systems, PODS \u201902, pp. 1\u201316. ACM, New York, NY, USA (2002)","DOI":"10.1145\/543613.543615"},{"issue":"2","key":"413_CR6","doi-asserted-by":"crossref","first-page":"121","DOI":"10.1007\/s00778-004-0147-z","volume":"15","author":"A Arasu","year":"2006","unstructured":"Arasu, A., Babu, S., Widom, J.: The CQL continuous query language: semantic foundations and query execution. VLDB J. 15(2), 121\u2013142 (2006)","journal-title":"VLDB J."},{"issue":"12","key":"413_CR7","doi-asserted-by":"crossref","first-page":"1135","DOI":"10.1002\/spe.1026","volume":"40","author":"H Gonz\u00e1lez-V\u00e8lez","year":"2010","unstructured":"Gonz\u00e1lez-V\u00e8lez, H., Leyton, M.: A survey of algorithmic skeleton frameworks: high-level structured parallel programming enablers. Softw. Pract. Exp. 40(12), 1135\u20131160 (2010)","journal-title":"Softw. Pract. Exp."},{"issue":"4","key":"413_CR8","doi-asserted-by":"crossref","first-page":"46:1","DOI":"10.1145\/2528412","volume":"46","author":"M Hirzel","year":"2014","unstructured":"Hirzel, M., Soul\u00e9, R., Schneider, S., Gedik, B., Grimm, R.: A catalog of stream processing optimizations. ACM Comput. Surv. 46(4), 46:1\u201346:34 (2014)","journal-title":"ACM Comput. Surv."},{"issue":"3","key":"413_CR9","doi-asserted-by":"crossref","first-page":"389","DOI":"10.1016\/j.parco.2003.12.002","volume":"30","author":"M Cole","year":"2004","unstructured":"Cole, M.: Bringing skeletons out of the closet: a pragmatic manifesto for skeletal parallel programming. Parallel Comput. 30(3), 389\u2013406 (2004)","journal-title":"Parallel Comput."},{"key":"413_CR10","unstructured":"Fastflow (ff). http:\/\/calvados.di.unipi.it\/fastflow\/ (2015)"},{"issue":"22","key":"413_CR11","doi-asserted-by":"crossref","first-page":"3843","DOI":"10.1016\/j.ins.2009.07.012","volume":"179","author":"SK Tanbeer","year":"2009","unstructured":"Tanbeer, S.K., Ahmed, C.F., Jeong, B.S., Lee, Y.K.: Sliding window-based frequent pattern mining over data streams. Inf. Sci. 179(22), 3843\u20133865 (2009)","journal-title":"Inf. Sci."},{"key":"413_CR12","volume-title":"Data Streams, Advances in Database Systems","author":"C Aggarwal","year":"2007","unstructured":"Aggarwal, C., Yu, P.: A survey of synopsis construction in data streams. In: Aggarwal, C. (ed.) Data Streams, Advances in Database Systems, vol. 31. Springer, New York (2007)"},{"issue":"1","key":"413_CR13","doi-asserted-by":"crossref","first-page":"42","DOI":"10.1016\/j.is.2010.02.001","volume":"36","author":"K Patroumpas","year":"2011","unstructured":"Patroumpas, K., Sellis, T.: Maintaining consistent results of continuous queries under diverse window specifications. Inf. Syst. 36(1), 42\u201361 (2011)","journal-title":"Inf. Syst."},{"issue":"4","key":"413_CR14","doi-asserted-by":"crossref","first-page":"517","DOI":"10.1007\/s00778-013-0335-9","volume":"23","author":"B Gedik","year":"2014","unstructured":"Gedik, B.: Partitioning functions for stateful data parallelism in stream processing. VLDB J. 23(4), 517\u2013539 (2014)","journal-title":"VLDB J."},{"key":"413_CR15","doi-asserted-by":"publisher","unstructured":"Bertolli, C., Mencagli, G., Vanneschi, M.: Analyzing memory requirements for pervasive grid applications. In: 2010 18th Euromicro International Conference on Parallel, Distributed and Network-Based Processing (PDP), pp. 297\u2013301 (2010). doi: 10.1109\/PDP.2010.71","DOI":"10.1109\/PDP.2010.71"},{"key":"413_CR16","doi-asserted-by":"publisher","unstructured":"Aldinucci, M., Calcagno, C., Coppo, M., Damiani, F., Drocco, M., Sciacca, E., Spinella, S., Torquati, M., Troina, A.: On designing multicore-aware simulators for systems biology endowed with online statistics. BioMed Res. Int. 2014, 207041 (2014). doi: 10.1155\/2014\/207041","DOI":"10.1155\/2014\/207041"},{"issue":"1","key":"413_CR17","doi-asserted-by":"crossref","first-page":"39","DOI":"10.1145\/1058150.1058158","volume":"34","author":"J Li","year":"2005","unstructured":"Li, J., Maier, D., Tufte, K., Papadimos, V., Tucker, P.A.: No pane, no gain: efficient evaluation of sliding-window aggregates over data streams. SIGMOD Rec. 34(1), 39\u201344 (2005)","journal-title":"SIGMOD Rec."},{"key":"413_CR18","unstructured":"Balkesen, C., Tatbul, N.: Scalable Data partitioning techniques for parallel sliding window processing over data streams. In: VLDB International Workshop on Data Management for Sensor Networks (DMSN\u201911). Seattle, WA, USA (2011)"},{"key":"413_CR19","doi-asserted-by":"crossref","unstructured":"Aldinucci, M., Danelutto, M., Kilpatrick, P., Meneghin, M., Torquati, M.: An efficient unbounded lock-free queue for multi-core systems. In: Proceedings of the 18th International Conference on Parallel Processing, Euro-Par\u201912, pp. 662\u2013673. Springer-Verlag, Berlin, Heidelberg (2012)","DOI":"10.1007\/978-3-642-32820-6_65"},{"key":"413_CR20","doi-asserted-by":"crossref","unstructured":"Dobra, A., Garofalakis, M., Gehrke, J., Rastogi, R.: Processing complex aggregate queries over data streams. In: Proceedings of the 2002 ACM SIGMOD International Conference on Management of Data, SIGMOD \u201902. ACM, New York, NY, USA (2002)","DOI":"10.1145\/564691.564699"},{"issue":"3","key":"413_CR21","doi-asserted-by":"crossref","first-page":"377","DOI":"10.1109\/TKDE.2006.48","volume":"18","author":"Y Tao","year":"2006","unstructured":"Tao, Y., Papadias, D.: Maintaining sliding window skylines on data streams. IEEE Trans. Knowl. Data Eng. 18(3), 377\u2013391 (2006)","journal-title":"IEEE Trans. Knowl. Data Eng."},{"issue":"4","key":"413_CR22","doi-asserted-by":"crossref","first-page":"1443","DOI":"10.1007\/s10586-014-0346-3","volume":"17","author":"G Mencagli","year":"2014","unstructured":"Mencagli, G., Vanneschi, M.: Towards a systematic approach to the dynamic adaptation of structured parallel computations using model predictive control. Clust. Comput. 17(4), 1443\u20131463 (2014)","journal-title":"Clust. Comput."}],"container-title":["International Journal of Parallel Programming"],"original-title":[],"language":"en","link":[{"URL":"http:\/\/link.springer.com\/content\/pdf\/10.1007\/s10766-016-0413-x.pdf","content-type":"application\/pdf","content-version":"vor","intended-application":"text-mining"},{"URL":"http:\/\/link.springer.com\/article\/10.1007\/s10766-016-0413-x\/fulltext.html","content-type":"text\/html","content-version":"vor","intended-application":"text-mining"},{"URL":"http:\/\/link.springer.com\/content\/pdf\/10.1007\/s10766-016-0413-x","content-type":"unspecified","content-version":"vor","intended-application":"similarity-checking"},{"URL":"http:\/\/link.springer.com\/content\/pdf\/10.1007\/s10766-016-0413-x.pdf","content-type":"application\/pdf","content-version":"vor","intended-application":"similarity-checking"}],"deposited":{"date-parts":[[2019,5,30]],"date-time":"2019-05-30T20:02:34Z","timestamp":1559246554000},"score":1,"resource":{"primary":{"URL":"http:\/\/link.springer.com\/10.1007\/s10766-016-0413-x"}},"subtitle":[],"short-title":[],"issued":{"date-parts":[[2016,3,25]]},"references-count":22,"journal-issue":{"issue":"2","published-print":{"date-parts":[[2017,4]]}},"alternative-id":["413"],"URL":"https:\/\/doi.org\/10.1007\/s10766-016-0413-x","relation":{},"ISSN":["0885-7458","1573-7640"],"issn-type":[{"value":"0885-7458","type":"print"},{"value":"1573-7640","type":"electronic"}],"subject":[],"published":{"date-parts":[[2016,3,25]]}}}