{"status":"ok","message-type":"work","message-version":"1.0.0","message":{"indexed":{"date-parts":[[2026,4,1]],"date-time":"2026-04-01T19:01:58Z","timestamp":1775070118881,"version":"3.50.1"},"reference-count":30,"publisher":"Springer Science and Business Media LLC","issue":"4","license":[{"start":{"date-parts":[[2013,8,31]],"date-time":"2013-08-31T00:00:00Z","timestamp":1377907200000},"content-version":"tdm","delay-in-days":0,"URL":"http:\/\/www.springer.com\/tdm"}],"content-domain":{"domain":[],"crossmark-restriction":false},"short-container-title":["The VLDB Journal"],"published-print":{"date-parts":[[2014,8]]},"DOI":"10.1007\/s00778-013-0335-9","type":"journal-article","created":{"date-parts":[[2013,8,30]],"date-time":"2013-08-30T04:29:48Z","timestamp":1377836988000},"page":"517-539","source":"Crossref","is-referenced-by-count":97,"title":["Partitioning functions for stateful data parallelism in stream processing"],"prefix":"10.1007","volume":"23","author":[{"given":"Bu\u011fra","family":"Gedik","sequence":"first","affiliation":[],"role":[{"role":"author","vocabulary":"crossref"}]}],"member":"297","published-online":{"date-parts":[[2013,8,31]]},"reference":[{"key":"335_CR1","unstructured":"Abadi, D., Ahmad, Y., Balazinska, M., \u00c7etintemel, U., Cherniack, M., Hwang, J.H., Lindner, W., Maskey, A., Rasin, A., Ryvkina, E., Tatbul, N., Xing, Y., Zdonik, S.: The design of the Borealis stream processing engine. In: Proceedings of the Innovative Data Systems Research Conference (CIDR), pp. 277\u2013289 (2005)"},{"key":"335_CR2","doi-asserted-by":"crossref","unstructured":"Arasu, A., Manku, G.S.: Approximate counts and quantiles over sliding windows. In: Proceedings of the Symposium on Principles of Database Systems (ACM PODS) (2004)","DOI":"10.1145\/1055558.1055598"},{"issue":"1","key":"335_CR3","first-page":"665","volume":"26","author":"A Arasu","year":"2003","unstructured":"Arasu, A., Babcock, B., Babu, S., Datar, M., Ito, K., Motwani, R., Nishizawa, I., Srivastava, U., Thomas, D., Varma, R., Widom, J.: STREAM: the stanford stream data manager. IEEE Data Eng. Bull. 26(1), 665 (2003)","journal-title":"IEEE Data Eng. Bull."},{"key":"335_CR4","unstructured":"Balkesen, C., Tatbul, N.: Scalable data partitioning techniques for parallel sliding window processing over data streams. In: International Workshop on Data Management for Sensor Networks (DMSN) (2011)"},{"key":"335_CR5","doi-asserted-by":"crossref","unstructured":"Cormode, G., Garofalakis, M., Haas, P., Jermaine, C.: Synopses for Massive Data: Samples, Histograms, Wavelets, Sketches. Now Publishing, Foundations and Trends in Databases Series (2011)","DOI":"10.1561\/1900000004"},{"key":"335_CR6","doi-asserted-by":"crossref","unstructured":"Deshpande, A., Ives, Z.G., Raman, V.: Adaptive query processing. Found. Trends Databases 1(1) (2007)","DOI":"10.1561\/1900000001"},{"key":"335_CR7","unstructured":"DeWitt, D., Naughton, J., Schneider, D., Seshadri, S.S.: Practical skew handling in parallel joins. In: Proceedings of the Very Large Data Bases Conference (VLDB) (1992)"},{"key":"335_CR8","doi-asserted-by":"crossref","unstructured":"Gates, A.F., Natkovich, O., Chopra, S., Kamath, P., Narayanamurthy, S.M., Olston, C., Reed, B., Srinivasan, S., Srivastava, U.: Building a high-level data flow system on top of map-reduce: The PIG experience. In: Proceedings of the Very Large Data Bases Conference (VLDB) (2009)","DOI":"10.14778\/1687553.1687568"},{"key":"335_CR9","unstructured":"Gedik, B., Schneider, S., Hirzel, M., Wu, K.L.: Elastic scaling for data stream processing. IBM Research Technical Report, RC25401 (2013)"},{"issue":"11","key":"335_CR10","doi-asserted-by":"crossref","first-page":"1363","DOI":"10.1002\/spe.1139","volume":"42","author":"B Gedik","year":"2012","unstructured":"Gedik, B., Andrade, H.: A model-based framework for building extensible, high performance stream processing middleware and programming language for IBM InfoSphere streams. Softw. Pract. Exp. 42(11), 1363\u20131391 (2012)","journal-title":"Softw. Pract. Exp."},{"key":"335_CR11","unstructured":"Gufler, B., Augsten, N., Reiser, A., Kemper, A.: Handling data skew in mapreduce. In: Proceedings of the International Conference of Cloud Computing and Services Science (2011)"},{"key":"335_CR12","doi-asserted-by":"crossref","unstructured":"Gufler, B., Augsten, N., Reiser, A., Kemper, A.: Load balancing in mapreduce based on scalable cardinality estimates. In: Proceedings of the International Conference on Data Engineering (IEEE ICDE) (2012)","DOI":"10.1109\/ICDE.2012.58"},{"key":"335_CR13","unstructured":"Hirzel, M., Andrade, H., Gedik, B., Kumar, V., Losa, G., Mendell, M., Nasgaard, H., Soul\u00e9, R., Wu, K.L.: SPL language spec. Tech. Rep. RC24897, IBM (2009)"},{"key":"335_CR14","doi-asserted-by":"crossref","unstructured":"Jain, N., Amini, L., Andrade, H., King, R., Park, Y., Selo, P., Venkatramani, C.: Design, implementation, and evaluation of the linear road benchmark on the stream processing core. In: Proceedings of the International Conference on Management of Data (ACM SIGMOD) (2006)","DOI":"10.1145\/1142473.1142522"},{"key":"335_CR15","doi-asserted-by":"crossref","unstructured":"Karger, D.R., Lehman, E., Leighton, T., Panigrahy, R., Levine, M., Lewin, D.: Consistent hashing and random trees: distributed caching protocols for relieving hot spots on the world wide web. In: Proceedings of the International Symposium on Theory of Computing (ACM STOC), pp. 654\u2013663 (1997)","DOI":"10.1145\/258533.258660"},{"issue":"11\u201316","key":"335_CR16","doi-asserted-by":"crossref","first-page":"1203","DOI":"10.1016\/S1389-1286(99)00055-9","volume":"31","author":"DR Karger","year":"1999","unstructured":"Karger, D.R., Sherman, A., Berkheimer, A., Bogstad, B., Dhanidina, R., Iwamoto, K., Kim, B., Matkins, L., Yerushalmi, Y.: Web caching with consistent hashing. Comput. Netw. 31(11\u201316), 1203\u20131213 (1999)","journal-title":"Comput. Netw."},{"key":"335_CR17","doi-asserted-by":"crossref","unstructured":"Kwon, Y., Balazinska, M., Howe, B., Rolia, J.A.: SkewTune: mitigating skew in mapreduce applications. In: Proceedings of the International Conference on Management of Data (ACM SIGMOD) (2012)","DOI":"10.1145\/2213836.2213840"},{"key":"335_CR18","doi-asserted-by":"crossref","unstructured":"Manku, G.S., Motwani, R.: Approximate frequency counts over data streams. In: Proceedings of the International Conference on Very Large Databases (VLDB) (2002)","DOI":"10.1016\/B978-155860869-6\/50038-X"},{"key":"335_CR19","unstructured":"MurMurHash3. http:\/\/code.google.com\/p\/smhasher\/wiki\/MurmurHash3 (2013). Retrieved May 2013"},{"key":"335_CR20","doi-asserted-by":"crossref","unstructured":"Paton, N.W., Chavez, J.B., Chen, M., Raman, V., Swart, G., Narang, I., Yellin, D.M., Fernandes, A.A.A.: Autonomic query parallelization using non-dedicated computers: An evaluation of adaptivity options. In: Proceedings of the Very Large Data Bases Conference (VLDB) (2009)","DOI":"10.1007\/s00778-007-0090-x"},{"key":"335_CR21","unstructured":"Poosala, V., Ioannidis, Y.E.: Estimation of query-result distribution and its application in parallel-join load balancing. In: Proceedings of the Very Large Data Bases Conference (VLDB) (1996)"},{"key":"335_CR22","unstructured":"S4 distributed stream computing platform. http:\/\/www.s4.io\/ (2012). Retrieved May 2012"},{"key":"335_CR23","doi-asserted-by":"crossref","unstructured":"Schneider, S., Andrade, H., Gedik, B., Biem, A., Wu, K.L.: Elastic scaling of data parallel operators in stream processing. In: Proceedings of the International Parallel and Distributed Processing Symposium (IEEE IPDPS) (2009)","DOI":"10.1109\/IPDPS.2009.5161036"},{"key":"335_CR24","doi-asserted-by":"crossref","unstructured":"Schneider, S., Hirzel, M., Gedik, B., Wu, K.L.: Auto-parallelizing stateful distributed streaming application. In: Proceedigns of the International Conference on Parallel Architectures and Compilation Techniques (PACT), pp. 53\u201364 (2012)","DOI":"10.1145\/2370816.2370826"},{"key":"335_CR25","doi-asserted-by":"crossref","unstructured":"Shah, M.A., Hellerstein, J.M., Chandrasekaran, S., Franklin, M.J.: Flux: An adaptive partitioning operator for continuous query systems. In: Proceedings of the International Conference on Data Engineering (IEEE ICDE) (2003)","DOI":"10.1109\/ICDE.2003.1260779"},{"key":"335_CR26","doi-asserted-by":"crossref","unstructured":"Shatdal, A., Naughton, J.: Adaptive parallel aggregation algorithms. In: Proceedings of the International Conference on Management of Data (ACM SIGMOD) (1995)","DOI":"10.1145\/223784.223801"},{"key":"335_CR27","unstructured":"Storm project. http:\/\/storm-project.net\/ (2012). Retrieved May 2012"},{"key":"335_CR28","unstructured":"StreamBase Systems. http:\/\/www.streambase.com (2012). Retr- ieved May 2012"},{"key":"335_CR29","unstructured":"Walton, C., Dale, A., Jenevein, R.: A taxonomy and performance model of data skew effects in parallel joins. In: Proceedings of the Very Large Data Bases Conference (VLDB) (1991)"},{"key":"335_CR30","doi-asserted-by":"crossref","unstructured":"Xu, Y., Kostamaa, P.: Efficient outer join data skew handling in parallel dbms. In: Proceedings of the Very Large Data Bases Conference (VLDB) (2009)","DOI":"10.14778\/1687553.1687565"}],"container-title":["The VLDB Journal"],"original-title":[],"language":"en","link":[{"URL":"http:\/\/link.springer.com\/content\/pdf\/10.1007\/s00778-013-0335-9.pdf","content-type":"application\/pdf","content-version":"vor","intended-application":"text-mining"},{"URL":"http:\/\/link.springer.com\/article\/10.1007\/s00778-013-0335-9\/fulltext.html","content-type":"text\/html","content-version":"vor","intended-application":"text-mining"},{"URL":"http:\/\/link.springer.com\/content\/pdf\/10.1007\/s00778-013-0335-9","content-type":"unspecified","content-version":"vor","intended-application":"similarity-checking"}],"deposited":{"date-parts":[[2019,7,22]],"date-time":"2019-07-22T17:09:36Z","timestamp":1563815376000},"score":1,"resource":{"primary":{"URL":"http:\/\/link.springer.com\/10.1007\/s00778-013-0335-9"}},"subtitle":[],"short-title":[],"issued":{"date-parts":[[2013,8,31]]},"references-count":30,"journal-issue":{"issue":"4","published-print":{"date-parts":[[2014,8]]}},"alternative-id":["335"],"URL":"https:\/\/doi.org\/10.1007\/s00778-013-0335-9","relation":{},"ISSN":["1066-8888","0949-877X"],"issn-type":[{"value":"1066-8888","type":"print"},{"value":"0949-877X","type":"electronic"}],"subject":[],"published":{"date-parts":[[2013,8,31]]}}}