{"status":"ok","message-type":"work","message-version":"1.0.0","message":{"indexed":{"date-parts":[[2026,5,14]],"date-time":"2026-05-14T00:05:28Z","timestamp":1778717128575,"version":"3.51.4"},"reference-count":39,"publisher":"Springer Science and Business Media LLC","issue":"5","license":[{"start":{"date-parts":[[2017,1,23]],"date-time":"2017-01-23T00:00:00Z","timestamp":1485129600000},"content-version":"unspecified","delay-in-days":0,"URL":"http:\/\/www.springer.com\/tdm"}],"content-domain":{"domain":["link.springer.com"],"crossmark-restriction":false},"short-container-title":["World Wide Web"],"published-print":{"date-parts":[[2017,9]]},"DOI":"10.1007\/s11280-017-0431-7","type":"journal-article","created":{"date-parts":[[2017,1,23]],"date-time":"2017-01-23T07:05:47Z","timestamp":1485155147000},"page":"1089-1110","update-policy":"https:\/\/doi.org\/10.1007\/springer_crossmark_policy","source":"Crossref","is-referenced-by-count":8,"title":["Distributed stream join under workload variance"],"prefix":"10.1007","volume":"20","author":[{"given":"Junhua","family":"Fang","sequence":"first","affiliation":[],"role":[{"role":"author","vocabulary":"crossref"}]},{"given":"Rong","family":"Zhang","sequence":"additional","affiliation":[],"role":[{"role":"author","vocabulary":"crossref"}]},{"given":"Xiaotong","family":"Wang","sequence":"additional","affiliation":[],"role":[{"role":"author","vocabulary":"crossref"}]},{"given":"Aoying","family":"Zhou","sequence":"additional","affiliation":[],"role":[{"role":"author","vocabulary":"crossref"}]}],"member":"297","published-online":{"date-parts":[[2017,1,23]]},"reference":[{"key":"431_CR1","unstructured":"Apache Storm. http:\/\/storm.apache.org\/"},{"key":"431_CR2","unstructured":"The TPC-H Benchmark. http:\/\/www.tpc.org\/tpch"},{"key":"431_CR3","doi-asserted-by":"crossref","unstructured":"Ananthanarayanan, R., Basker, V., Das, S., Gupta, A., Jiang, H., Qiu, T., Reznichenko, A., Ryabkov, D., Singh, M., Venkataraman, S.: Photon: fault-tolerant and scalable joining of continuous data streams. In: SIGMOD, pp 577\u2013588 (2013)","DOI":"10.1145\/2463676.2465272"},{"key":"431_CR4","doi-asserted-by":"crossref","unstructured":"Anis Uddin Nasir, M., De Francisci Morales, G., et al.: The power of both choices: Practical load balancing for distributed stream processing engines. In: ICDE, pp 137\u2013148 (2015)","DOI":"10.1109\/ICDE.2015.7113279"},{"issue":"1","key":"431_CR5","doi-asserted-by":"crossref","first-page":"58","DOI":"10.1016\/j.jalgor.2003.12.001","volume":"55","author":"G Cormode","year":"2005","unstructured":"Cormode, G., Muthukrishnan, S.: An improved data stream summary: the count-min sketch and its applications. Journal of Algorithms 55(1), 58\u201375 (2005)","journal-title":"Journal of Algorithms"},{"key":"431_CR6","doi-asserted-by":"crossref","unstructured":"Dittrich, J.P., Seeger, B., Taylor, D.S., Widmayer, P.: Progressive merge join: A generic and non-blocking sort-based join algorithm. In: VLDB, pp 299\u2013310 (2002)","DOI":"10.1016\/B978-155860869-6\/50034-2"},{"key":"431_CR7","doi-asserted-by":"crossref","unstructured":"Elseidy, M., Elguindy, A., Vitorovic, A., Koch, C.: Scalable and adaptive online joins. In: VLDB, pp 441\u2013452 (2014)","DOI":"10.14778\/2732279.2732281"},{"key":"431_CR8","doi-asserted-by":"crossref","unstructured":"Epstein, R. S., Stonebraker, M., Wong, E.: Distributed query processing in a relational data base system. In: SIGMOD, pp 169\u2013180 (1978)","DOI":"10.1145\/509252.509292"},{"key":"431_CR9","doi-asserted-by":"crossref","unstructured":"Fang, J., Wang, X., Zhang, R., Zhou, A.: Flexible and adaptive stream join algorithm. In: APWEB, pp 3\u201316 (2016)","DOI":"10.1007\/978-3-319-45817-5_1"},{"key":"431_CR10","doi-asserted-by":"crossref","unstructured":"Fang, J., Zhang, R., Fu, T.Z.J., Zhang, Z., Zhou, A., Zhu, J.: Parallel stream processing against workload skewness and variance. CoRR, abs\/1610.05121 (2016)","DOI":"10.1145\/3078597.3078613"},{"issue":"4","key":"431_CR11","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."},{"issue":"2","key":"431_CR12","doi-asserted-by":"crossref","first-page":"73","DOI":"10.1145\/152610.152611","volume":"25","author":"G Graefe","year":"1993","unstructured":"Graefe, G.: Query evaluation techniques for large databases. ACM Comput. Surv. (CSUR) 25(2), 73\u2013169 (1993)","journal-title":"ACM Comput. Surv. (CSUR)"},{"key":"431_CR13","doi-asserted-by":"crossref","unstructured":"Huang, X., Cheng, H., Li, R.-H., Qin, L., Yu, J.X.: Top-k structural diversity search in large networks. In: VLDB, pp 1618\u20131629 (2013)","DOI":"10.14778\/2536258.2536272"},{"key":"431_CR14","doi-asserted-by":"crossref","unstructured":"Huebsch, R., Garofalakis, M., Hellerstein, J., Stoica, I.: Advanced join strategies for large-scale distributed computation. In: VLDB, pp 1484\u20131495 (2014)","DOI":"10.14778\/2733004.2733020"},{"key":"431_CR15","doi-asserted-by":"crossref","unstructured":"Ives, Z.G., Florescu, D., Friedman, M., Levy, A., Weld, D.S.: An adaptive query execution system for data integration, vol. 28, pp 299\u2013310. ACM (1999)","DOI":"10.1145\/304181.304209"},{"key":"431_CR16","doi-asserted-by":"crossref","unstructured":"Kwon, Y., Balazinska, M., et al.: Skewtune: mitigating skew in mapreduce applications. In: SIGMOD, pp 25\u201336 (2012)","DOI":"10.1145\/2213836.2213840"},{"key":"431_CR17","doi-asserted-by":"crossref","first-page":"81","DOI":"10.1016\/j.compind.2014.09.004","volume":"69","author":"J Li","year":"2015","unstructured":"Li, J., Liu, C., Liu, B., Mao, R., Wang, Y., Chen, S., Yang, J.-J., Pan, H., Wang, Q.: Diversity-aware retrieval of medical records. Comput. Ind. 69, 81\u201391 (2015)","journal-title":"Comput. Ind."},{"key":"431_CR18","doi-asserted-by":"crossref","unstructured":"Lin, Q., Ooi, B.C., Wang, Z., Yu, C.: Scalable distributed stream join processing. In: SIGMOD, pp 811\u2013825 (2015)","DOI":"10.1145\/2723372.2746485"},{"key":"431_CR19","unstructured":"Liu, B., Zhu, Y., Jbantova, M., et al.: and A dynamically adaptive distributed system for processing complex continuous queries. In: VLDB, pp 1338\u20131341 (2005)"},{"key":"431_CR20","doi-asserted-by":"crossref","first-page":"61","DOI":"10.1016\/j.compind.2014.09.006","volume":"69","author":"M Lu","year":"2015","unstructured":"Lu, M., Tang, Y., Sun, R., Wang, T., Chen, S., Mao, R.: A real time displacement estimation algorithm for ultrasound elastography. Comput. Ind. 69, 61\u201371 (2015)","journal-title":"Comput. Ind."},{"issue":"1","key":"431_CR21","doi-asserted-by":"crossref","first-page":"42","DOI":"10.1109\/MCOM.2015.7010514","volume":"53","author":"R Mao","year":"2015","unstructured":"Mao, R., Xu, H., Wu, W., Li, J., Li, Y., Lu, M.: Overcoming the challenge of variety: big data abstraction, the next evolution of data management for aal communication systems. Communications Magazine, IEEE 53(1), 42\u201347 (2015)","journal-title":"Communications Magazine, IEEE"},{"issue":"2","key":"431_CR22","doi-asserted-by":"crossref","first-page":"311","DOI":"10.1007\/s13042-016-0504-4","volume":"7","author":"R Mao","year":"2016","unstructured":"Mao, R., Zhang, P., Li, X., Liu, X., Lu, M.: Pivot selection for metric-space indexing. Int. J. Mach. Learn. Cybern. 7(2), 311\u2013323 (2016)","journal-title":"Int. J. Mach. Learn. Cybern."},{"key":"431_CR23","doi-asserted-by":"crossref","unstructured":"Nasir, M.A.U., Serafini, M., et al.: When two choices are not enough: Balancing at scale in distributed stream processing. In: ICDE (2016)","DOI":"10.1109\/ICDE.2016.7498273"},{"key":"431_CR24","doi-asserted-by":"crossref","unstructured":"Okcan, A., Riedewald, M.: Processing theta-joins using mapreduce. In: SIGMOD, pp 949\u2013960 (2011)","DOI":"10.1145\/1989323.1989423"},{"key":"431_CR25","doi-asserted-by":"crossref","unstructured":"Qian, Z., He, Y., Su, C., Wu, Z., Zhu, H., Zhang, T., Zhou, L., Yu, Y., Zhang, Z.: Timestream: reliable stream computation in the cloud. In: Eurosys, pp 1\u201314 (2013)","DOI":"10.1145\/2465351.2465353"},{"issue":"12","key":"431_CR26","doi-asserted-by":"crossref","first-page":"1345","DOI":"10.1109\/71.250116","volume":"4","author":"JW Stamos","year":"1993","unstructured":"Stamos, J.W., Young, H.C.: A symmetric and replicate algorithm for distributed joins. IEEE Trans. Parallel Distrib. Syst. 4(12), 1345\u20131354 (1993)","journal-title":"IEEE Trans. Parallel Distrib. Syst."},{"key":"431_CR27","doi-asserted-by":"crossref","unstructured":"Tao, Y., Yiu, M., Papadias, D., et al.: Rpj: Producing fasj join results on streams through rate-based optimization. In: SIGMOD, pp 371\u2013382 (2005)","DOI":"10.1145\/1066157.1066200"},{"key":"431_CR28","doi-asserted-by":"crossref","unstructured":"ufler, N., Augsten, B., Reiser, A., Kemper, A.: Load balancing in mapreduce based on scalable cardinality estimates. In: ICDE, pp 522\u2013533 (2012)","DOI":"10.1109\/ICDE.2012.58"},{"key":"431_CR29","unstructured":"Urhan, T., Franklin, M.J.: Xjoin: A reactively-scheduled pipelined join operatory\u0300 Bulletin of the Technical Committee (2000)"},{"key":"431_CR30","doi-asserted-by":"crossref","unstructured":"Vitorovic, A., ElSeidy, M., Koch, C.: Load balancing and skew resilience for parallel joins. In: ICDE (2016)","DOI":"10.1109\/ICDE.2016.7498250"},{"key":"431_CR31","doi-asserted-by":"crossref","first-page":"195","DOI":"10.1016\/j.neucom.2015.04.076","volume":"167","author":"J Wang","year":"2015","unstructured":"Wang, J., Huang, J.Z., Guo, J., Lan, Y.: Recommending high-utility search engine queries via a query-recommending model. Neurocomputing 167, 195\u2013208 (2015)","journal-title":"Neurocomputing"},{"issue":"1","key":"431_CR32","doi-asserted-by":"crossref","first-page":"103","DOI":"10.1007\/BF01277522","volume":"1","author":"A Wilschut","year":"1993","unstructured":"Wilschut, A., Apers, P.: Dataflow query execution in a aarallel main-memory environment. Distributed and Parallel Databases 1(1), 103\u2013128 (1993)","journal-title":"Distributed and Parallel Databases"},{"key":"431_CR33","unstructured":"Xing, Y., Hwang, J., Cetintemel, U., Zdonik, S.: Providing resiliency to load variations in distributed stream processing. In: VLDB, pp 775\u2013786 (2006)"},{"key":"431_CR34","doi-asserted-by":"crossref","unstructured":"Xu, Y., Kostamaa, P., Zhou, X., Chen, L.: Handling data skew in parallel joins in shared-nothing systems. In: SIGMOD, pp 1043\u20131052 (2008)","DOI":"10.1145\/1376616.1376720"},{"key":"431_CR35","doi-asserted-by":"crossref","unstructured":"Zaharia, M., Das, T., Li, H., Hunter, T., Shenker, S., Stoica, I.: Discretized streams: Fault-tolerant streaming computation at scale. In: SOSP, pp 423\u2013438. ACM (2013)","DOI":"10.1145\/2517349.2522737"},{"key":"431_CR36","doi-asserted-by":"crossref","unstructured":"Zheng, B., Zheng, K., Xiao, X., Su, H., Yin, H., Zhou, X., Li, G.: Keyword-aware continuous knn query on road networks. In: ICDE, pp 871\u2013882 (2016)","DOI":"10.1109\/ICDE.2016.7498297"},{"key":"431_CR37","doi-asserted-by":"crossref","unstructured":"Zheng, K., Zheng, Y., Yuan, N.J., Shang, S.: On discovery of gathering patterns from trajectories. In: ICDE, pp 242\u2013253 (2013)","DOI":"10.1109\/ICDE.2013.6544829"},{"issue":"8","key":"431_CR38","doi-asserted-by":"crossref","first-page":"1974","DOI":"10.1109\/TKDE.2013.160","volume":"26","author":"K Zheng","year":"2014","unstructured":"Zheng, K., Zheng, Y., Yuan, N.J., Shang, S., Zhou, X.: Online discovery of gathering patterns over trajectories. IEEE Trans. Knowl. Data Eng. 26(8), 1974\u20131988 (2014)","journal-title":"IEEE Trans. Knowl. Data Eng."},{"issue":"4","key":"431_CR39","doi-asserted-by":"crossref","first-page":"387","DOI":"10.3233\/ICA-150498","volume":"22","author":"Z Zhu","year":"2015","unstructured":"Zhu, Z., Xiao, J., Li, J., Wang, F., Zhang, Q.: Global path planning of wheeled robots using multi-objective memetic algorithms. Integrated Computer-Aided Engineering 22(4), 387\u2013404 (2015)","journal-title":"Integrated Computer-Aided Engineering"}],"container-title":["World Wide Web"],"original-title":[],"language":"en","link":[{"URL":"http:\/\/link.springer.com\/article\/10.1007\/s11280-017-0431-7\/fulltext.html","content-type":"text\/html","content-version":"vor","intended-application":"text-mining"},{"URL":"http:\/\/link.springer.com\/content\/pdf\/10.1007\/s11280-017-0431-7.pdf","content-type":"application\/pdf","content-version":"vor","intended-application":"text-mining"},{"URL":"http:\/\/link.springer.com\/content\/pdf\/10.1007\/s11280-017-0431-7.pdf","content-type":"application\/pdf","content-version":"vor","intended-application":"similarity-checking"}],"deposited":{"date-parts":[[2019,9,17]],"date-time":"2019-09-17T17:58:26Z","timestamp":1568743106000},"score":1,"resource":{"primary":{"URL":"http:\/\/link.springer.com\/10.1007\/s11280-017-0431-7"}},"subtitle":[],"short-title":[],"issued":{"date-parts":[[2017,1,23]]},"references-count":39,"journal-issue":{"issue":"5","published-print":{"date-parts":[[2017,9]]}},"alternative-id":["431"],"URL":"https:\/\/doi.org\/10.1007\/s11280-017-0431-7","relation":{},"ISSN":["1386-145X","1573-1413"],"issn-type":[{"value":"1386-145X","type":"print"},{"value":"1573-1413","type":"electronic"}],"subject":[],"published":{"date-parts":[[2017,1,23]]}}}