{"status":"ok","message-type":"work","message-version":"1.0.0","message":{"indexed":{"date-parts":[[2025,11,8]],"date-time":"2025-11-08T22:47:29Z","timestamp":1762642049971,"version":"3.41.0"},"reference-count":16,"publisher":"Association for Computing Machinery (ACM)","issue":"3","license":[{"start":{"date-parts":[[2017,10,31]],"date-time":"2017-10-31T00:00:00Z","timestamp":1509408000000},"content-version":"vor","delay-in-days":0,"URL":"https:\/\/www.acm.org\/publications\/policies\/copyright_policy#Background"}],"content-domain":{"domain":["dl.acm.org"],"crossmark-restriction":true},"short-container-title":["SIGMOD Rec."],"published-print":{"date-parts":[[2017,10,31]]},"abstract":"<jats:p>CHive is a new streaming analytics platform to run distributed SQL-style queries on edge clouds. However, CHive is currently tightly coupled to a specific stream processing system (SPS), Apache Storm. In this paper we address the decoupling of the CHive query planner and optimizer from the runtime environment, and also extend the latter to support pluggable runtimes through a common API. As runtimes, we currently support Apache Spark and Flink streaming. The fundamental contribution of this paper is to assess the cost of employing interstream parallelism in SPS. Experimental evaluation indicates that we can enable popular SPS to be distributed on edge clouds with stable overhead in terms of throughput<\/jats:p>","DOI":"10.1145\/3156655.3156661","type":"journal-article","created":{"date-parts":[[2017,11,1]],"date-time":"2017-11-01T12:45:06Z","timestamp":1509540306000},"page":"23-28","update-policy":"https:\/\/doi.org\/10.1145\/crossmark-policy","source":"Crossref","is-referenced-by-count":4,"title":["Empowering Stream Processing through Edge Clouds"],"prefix":"10.1145","volume":"46","author":[{"given":"Sergi","family":"Esteves","sequence":"first","affiliation":[{"name":"INESC-ID, Instituto Superior Tecnico, Universidade de Lisboa"}],"role":[{"role":"author","vocabulary":"crossref"}]},{"given":"Nico","family":"Janssens","sequence":"additional","affiliation":[{"name":"Bell Labs, Nokia, Antwerp"}],"role":[{"role":"author","vocabulary":"crossref"}]},{"given":"Bart","family":"Theeten","sequence":"additional","affiliation":[{"name":"Bell Labs, Nokia, Antwerp"}],"role":[{"role":"author","vocabulary":"crossref"}]},{"given":"Luis","family":"Veiga","sequence":"additional","affiliation":[{"name":"INESC-ID, Instituto Superior Tecnico, Universidade de Lisboa"}],"role":[{"role":"author","vocabulary":"crossref"}]}],"member":"320","published-online":{"date-parts":[[2017,10,31]]},"reference":[{"key":"e_1_2_1_1_1","unstructured":"Apache Edgent. http:\/\/edgent.incubator.apache.org\/.  Apache Edgent. http:\/\/edgent.incubator.apache.org\/."},{"key":"e_1_2_1_2_1","unstructured":"Apache Flink. http:\/\/flink.apache.org\/.  Apache Flink. http:\/\/flink.apache.org\/."},{"key":"e_1_2_1_3_1","unstructured":"Apache MRQL. https:\/\/mrql.incubator.apache.org\/.  Apache MRQL. https:\/\/mrql.incubator.apache.org\/."},{"key":"e_1_2_1_4_1","unstructured":"Apache Spark. http:\/\/spark.apache.org\/.  Apache Spark. http:\/\/spark.apache.org\/."},{"key":"e_1_2_1_5_1","unstructured":"Apache Storm. http:\/\/storm.apache.org\/.  Apache Storm. http:\/\/storm.apache.org\/."},{"key":"e_1_2_1_6_1","unstructured":"Streaming SQL for Apache Spark. https:\/\/github.com\/Intel-bigdata\/spark-streamingsql.  Streaming SQL for Apache Spark. https:\/\/github.com\/Intel-bigdata\/spark-streamingsql."},{"key":"e_1_2_1_7_1","doi-asserted-by":"publisher","DOI":"10.1145\/2723372.2742797"},{"key":"e_1_2_1_8_1","doi-asserted-by":"publisher","DOI":"10.1145\/603867.603884"},{"key":"e_1_2_1_9_1","volume-title":"Scalable Distributed Stream Processing. In CIDR 2003 - First Biennial Conference on Innovative Data Systems Research","author":"Cherniack M.","year":"2003","unstructured":"M. Cherniack , H. Balakrishnan , M. Balazinska , D. Carney , U. Cetintemel , Y. Xing , and S. Zdonik . Scalable Distributed Stream Processing. In CIDR 2003 - First Biennial Conference on Innovative Data Systems Research , Asilomar, CA , January 2003 . M. Cherniack, H. Balakrishnan, M. Balazinska, D. Carney, U. Cetintemel, Y. Xing, and S. Zdonik. Scalable Distributed Stream Processing. In CIDR 2003 - First Biennial Conference on Innovative Data Systems Research, Asilomar, CA, January 2003."},{"key":"e_1_2_1_10_1","doi-asserted-by":"publisher","DOI":"10.1145\/1376616.1376729"},{"key":"e_1_2_1_11_1","doi-asserted-by":"publisher","DOI":"10.1109\/ICDE.2004.1320080"},{"key":"e_1_2_1_12_1","first-page":"245","volume-title":"Proceedings of the First Biennial Conference on Innovative Data Systems Research (CIDR)","author":"Motwani R.","year":"2003","unstructured":"R. Motwani , J. Widom , A. Arasu , B. Babcock , S. Babu , M. Datar , G. Manku , C. Olston , J. Rosenstein , and R. Varma . Query processing, resource management, and approximation in a data stream management system . In Proceedings of the First Biennial Conference on Innovative Data Systems Research (CIDR) , pages 245 - 256 , Asilomar, California , Jan. 2003 . R. Motwani, J. Widom, A. Arasu, B. Babcock, S. Babu, M. Datar, G. Manku, C. Olston, J. Rosenstein, and R. Varma. Query processing, resource management, and approximation in a data stream management system. In Proceedings of the First Biennial Conference on Innovative Data Systems Research (CIDR), pages 245-256, Asilomar, California, Jan. 2003."},{"key":"e_1_2_1_13_1","doi-asserted-by":"publisher","DOI":"10.1145\/2785956.2787505"},{"key":"e_1_2_1_14_1","doi-asserted-by":"publisher","DOI":"10.1145\/1107499.1107504"},{"issue":"2","key":"e_1_2_1_15_1","first-page":"219","article-title":"Chive: Bandwidth optimized continuous querying in distributed clouds. Cloud Computing","volume":"3","author":"Theeten B.","year":"2015","unstructured":"B. Theeten and N. Janssens . Chive: Bandwidth optimized continuous querying in distributed clouds. Cloud Computing , IEEE Transactions on , 3 ( 2 ): 219 - 232 , April 2015 . B. Theeten and N. Janssens. Chive: Bandwidth optimized continuous querying in distributed clouds. Cloud Computing, IEEE Transactions on, 3(2):219-232, April 2015.","journal-title":"IEEE Transactions on"},{"key":"e_1_2_1_16_1","first-page":"10","volume-title":"Object and Component-Oriented Real-Time Distributed Computing, 2006. ISORC 2006. Ninth IEEE International Symposium on","author":"Wei Y.","year":"2006","unstructured":"Y. Wei , S. H. Son , and J. A. Stankovic . Rtstream: real-time query processing for data streams . In Object and Component-Oriented Real-Time Distributed Computing, 2006. ISORC 2006. Ninth IEEE International Symposium on , pages 10 pp.-, April 2006 . Y. Wei, S. H. Son, and J. A. Stankovic. Rtstream: real-time query processing for data streams. In Object and Component-Oriented Real-Time Distributed Computing, 2006. ISORC 2006. Ninth IEEE International Symposium on, pages 10 pp.-, April 2006."}],"container-title":["ACM SIGMOD Record"],"original-title":[],"language":"en","link":[{"URL":"https:\/\/dl.acm.org\/doi\/10.1145\/3156655.3156661","content-type":"unspecified","content-version":"vor","intended-application":"text-mining"},{"URL":"https:\/\/dl.acm.org\/doi\/pdf\/10.1145\/3156655.3156661","content-type":"unspecified","content-version":"vor","intended-application":"similarity-checking"}],"deposited":{"date-parts":[[2025,6,18]],"date-time":"2025-06-18T04:38:44Z","timestamp":1750221524000},"score":1,"resource":{"primary":{"URL":"https:\/\/dl.acm.org\/doi\/10.1145\/3156655.3156661"}},"subtitle":[],"short-title":[],"issued":{"date-parts":[[2017,10,31]]},"references-count":16,"journal-issue":{"issue":"3","published-print":{"date-parts":[[2017,10,31]]}},"alternative-id":["10.1145\/3156655.3156661"],"URL":"https:\/\/doi.org\/10.1145\/3156655.3156661","relation":{},"ISSN":["0163-5808"],"issn-type":[{"type":"print","value":"0163-5808"}],"subject":[],"published":{"date-parts":[[2017,10,31]]},"assertion":[{"value":"2017-10-31","order":2,"name":"published","label":"Published","group":{"name":"publication_history","label":"Publication History"}}]}}