{"status":"ok","message-type":"work","message-version":"1.0.0","message":{"indexed":{"date-parts":[[2024,8,9]],"date-time":"2024-08-09T07:13:19Z","timestamp":1723187599247},"reference-count":12,"publisher":"Association for Computing Machinery (ACM)","issue":"12","content-domain":{"domain":[],"crossmark-restriction":false},"short-container-title":["Proc. VLDB Endow."],"published-print":{"date-parts":[[2015,8]]},"abstract":"The widespread use of location-aware devices together with the increased popularity of micro-blogging applications (e.g., Twitter) led to the creation of large streams of spatio-textual data. In order to serve real-time applications, the processing of these large-scale spatio-textual streams needs to be distributed. However, existing distributed stream processing systems (e.g., Spark and Storm) are not optimized for spatial\/textual content. In this demonstration, we introduce Tornado, a distributed in-memory spatio-textual stream processing server that extends Storm. To efficiently process spatio-textual streams, Tornado introduces a spatio-textual indexing layer to the architecture of Storm. The indexing layer is adaptive, i.e., dynamically re-distributes the processing across the system according to changes in the data distribution and\/or query workload. In addition to keywords, higher-level textual concepts are identified and are semantically matched against spatio-textual queries. Tornado provides data deduplication and fusion to eliminate redundant textual data. We demonstrate a prototype of Tornado running against real Twitter streams, where the users can register continuous or snapshot spatio-textual queries using a map-assisted query-interface.<\/jats:p>","DOI":"10.14778\/2824032.2824126","type":"journal-article","created":{"date-parts":[[2015,9,16]],"date-time":"2015-09-16T12:18:17Z","timestamp":1442405897000},"page":"2020-2023","source":"Crossref","is-referenced-by-count":38,"title":["Tornado"],"prefix":"10.14778","volume":"8","author":[{"given":"Ahmed R.","family":"Mahmood","sequence":"first","affiliation":[{"name":"Purdue University, West Lafayette, IN"}]},{"given":"Ahmed M.","family":"Aly","sequence":"additional","affiliation":[{"name":"Purdue University, West Lafayette, IN"}]},{"given":"Thamir","family":"Qadah","sequence":"additional","affiliation":[{"name":"Purdue University, West Lafayette, IN"}]},{"given":"El Kindi","family":"Rezig","sequence":"additional","affiliation":[{"name":"Purdue University, West Lafayette, IN"}]},{"given":"Anas","family":"Daghistani","sequence":"additional","affiliation":[{"name":"Purdue University, West Lafayette, IN"}]},{"given":"Amgad","family":"Madkour","sequence":"additional","affiliation":[{"name":"Purdue University, West Lafayette, IN"}]},{"given":"Ahmed S.","family":"Abdelhamid","sequence":"additional","affiliation":[{"name":"Purdue University, West Lafayette, IN"}]},{"given":"Mohamed S.","family":"Hassan","sequence":"additional","affiliation":[{"name":"Purdue University, West Lafayette, IN"}]},{"given":"Walid G.","family":"Aref","sequence":"additional","affiliation":[{"name":"Purdue University, West Lafayette, IN"}]},{"given":"Saleh","family":"Basalamah","sequence":"additional","affiliation":[{"name":"Umm AlQura University, Makkah, KSA"}]}],"member":"320","published-online":{"date-parts":[[2015,8]]},"reference":[{"key":"e_1_2_1_1_1","volume-title":"http:\/\/hadoop.apache.org\/","year":"2015","unstructured":"Hadoop. http:\/\/hadoop.apache.org\/ , 2015 . Hadoop. http:\/\/hadoop.apache.org\/, 2015."},{"key":"e_1_2_1_2_1","volume-title":"http:\/\/www.openstreetmap.org\/","year":"2015","unstructured":"OpenStreetMap. http:\/\/www.openstreetmap.org\/ , 2015 . OpenStreetMap. http:\/\/www.openstreetmap.org\/, 2015."},{"key":"e_1_2_1_3_1","volume-title":"https:\/\/spark.apache.org\/","year":"2015","unstructured":"Spark. https:\/\/spark.apache.org\/ , 2015 . Spark. https:\/\/spark.apache.org\/, 2015."},{"key":"e_1_2_1_4_1","volume-title":"https:\/\/storm.apache.org\/","year":"2015","unstructured":"Storm. https:\/\/storm.apache.org\/ , 2015 . Storm. https:\/\/storm.apache.org\/, 2015."},{"key":"e_1_2_1_5_1","volume-title":"https:\/\/zookeeper.apache.org\/","year":"2015","unstructured":"ZooKeeper. https:\/\/zookeeper.apache.org\/ , 2015 . ZooKeeper. https:\/\/zookeeper.apache.org\/, 2015."},{"key":"e_1_2_1_6_1","doi-asserted-by":"publisher","DOI":"10.14778\/2536274.2536283"},{"key":"e_1_2_1_7_1","volume-title":"ICDE","author":"Lu J.","year":"2014","unstructured":"J. Lu and R. H. Guting . Parallel secondo: A practical system for large-scale processing of moving objects . In ICDE , 2014 . J. Lu and R. H. Guting. Parallel secondo: A practical system for large-scale processing of moving objects. In ICDE, 2014."},{"key":"e_1_2_1_8_1","volume-title":"Web-Age Information Management","author":"Ma Y.","year":"2013","unstructured":"Y. Ma , Y. Zhang , and X. Meng . St-hbase: a scalable data management system for massive geo-tagged objects . In Web-Age Information Management . Springer , 2013 . 10.1007\/978-3-642-38562-9_16 Y. Ma, Y. Zhang, and X. Meng. St-hbase: a scalable data management system for massive geo-tagged objects. In Web-Age Information Management. Springer, 2013. 10.1007\/978-3-642-38562-9_16"},{"key":"e_1_2_1_9_1","volume-title":"SIGSPATIAL","author":"Magdy A.","year":"2014","unstructured":"A. Magdy , L. Alarabi , S. Al-Harthi , M. Musleh , T. M. Ghanem , S. Ghani , and M. F. Mokbel . Taghreed: A system for querying, analyzing, and visualizing geotagged microblogs . SIGSPATIAL , 2014 . 10.1145\/2666310.2666397 A. Magdy, L. Alarabi, S. Al-Harthi, M. Musleh, T. M. Ghanem, S. Ghani, and M. F. Mokbel. Taghreed: A system for querying, analyzing, and visualizing geotagged microblogs. SIGSPATIAL, 2014. 10.1145\/2666310.2666397"},{"key":"e_1_2_1_10_1","volume-title":"SIGSPATIAL","author":"Mahmood A. R.","year":"2014","unstructured":"A. R. Mahmood , W. G. Aref , A. M. Aly , and S. Basalamah . Indexing recent trajectories of moving objects . In SIGSPATIAL , 2014 . 10.1145\/2666310.2666427 A. R. Mahmood, W. G. Aref, A. M. Aly, and S. Basalamah. Indexing recent trajectories of moving objects. In SIGSPATIAL, 2014. 10.1145\/2666310.2666427"},{"key":"e_1_2_1_11_1","volume-title":"SSTD.","author":"Mokbel M. F.","year":"2013","unstructured":"M. F. Mokbel , L. Alarabi , J. Bao , A. Eldawy , A. Magdy , M. Sarwat , E. Waytas , and S. Yackel . MNTG: an extensible web-based traffic generator . In SSTD. 2013 . 10.1007\/978-3-642-40235-7_3 M. F. Mokbel, L. Alarabi, J. Bao, A. Eldawy, A. Magdy, M. Sarwat, E. Waytas, and S. Yackel. MNTG: an extensible web-based traffic generator. In SSTD. 2013. 10.1007\/978-3-642-40235-7_3"},{"key":"e_1_2_1_12_1","volume-title":"CIKM","author":"Sutherland T. M.","year":"2005","unstructured":"T. M. Sutherland , B. Liu , M. Jbantova , and E. A. Rundensteiner . D-cape: distributed and self-tuned continuous query processing . In CIKM , 2005 . 10.1145\/1099554.1099595 T. M. Sutherland, B. Liu, M. Jbantova, and E. A. Rundensteiner. D-cape: distributed and self-tuned continuous query processing. In CIKM, 2005. 10.1145\/1099554.1099595"}],"container-title":["Proceedings of the VLDB Endowment"],"original-title":[],"language":"en","link":[{"URL":"https:\/\/dl.acm.org\/doi\/pdf\/10.14778\/2824032.2824126","content-type":"unspecified","content-version":"vor","intended-application":"similarity-checking"}],"deposited":{"date-parts":[[2022,12,28]],"date-time":"2022-12-28T10:04:01Z","timestamp":1672221841000},"score":1,"resource":{"primary":{"URL":"https:\/\/dl.acm.org\/doi\/10.14778\/2824032.2824126"}},"subtitle":["a distributed spatio-textual stream processing system"],"short-title":[],"issued":{"date-parts":[[2015,8]]},"references-count":12,"journal-issue":{"issue":"12","published-print":{"date-parts":[[2015,8]]}},"alternative-id":["10.14778\/2824032.2824126"],"URL":"https:\/\/doi.org\/10.14778\/2824032.2824126","relation":{},"ISSN":["2150-8097"],"issn-type":[{"value":"2150-8097","type":"print"}],"subject":[],"published":{"date-parts":[[2015,8]]}}}