{"status":"ok","message-type":"work","message-version":"1.0.0","message":{"indexed":{"date-parts":[[2026,2,20]],"date-time":"2026-02-20T18:31:29Z","timestamp":1771612289873,"version":"3.50.1"},"reference-count":30,"publisher":"MDPI AG","issue":"12","license":[{"start":{"date-parts":[[2021,6,17]],"date-time":"2021-06-17T00:00:00Z","timestamp":1623888000000},"content-version":"vor","delay-in-days":0,"URL":"https:\/\/creativecommons.org\/licenses\/by\/4.0\/"}],"funder":[{"DOI":"10.13039\/501100005969","name":"Universit\u00e0 di Bologna","doi-asserted-by":"publisher","award":["H2020SIMDOME"],"award-info":[{"award-number":["H2020SIMDOME"]}],"id":[{"id":"10.13039\/501100005969","id-type":"DOI","asserted-by":"publisher"}]}],"content-domain":{"domain":[],"crossmark-restriction":false},"short-container-title":["Sensors"],"abstract":"<jats:p>Large amounts of georeferenced data streams arrive daily to stream processing systems. This is attributable to the overabundance of affordable IoT devices. In addition, interested practitioners desire to exploit Internet of Things (IoT) data streams for strategic decision-making purposes. However, mobility data are highly skewed and their arrival rates fluctuate. This nature poses an extra challenge on data stream processing systems, which are required in order to achieve pre-specified latency and accuracy goals. In this paper, we propose ApproxSSPS, which is a system for approximate processing of geo-referenced mobility data, at scale with quality of service guarantees. We focus on stateful aggregations (e.g., means, counts) and top-N queries. ApproxSSPS features a controller that interactively learns the latency statistics and calculates proper sampling rates to meet latency or\/and accuracy targets. An overarching trait of ApproxSSPS is its ability to strike a plausible balance between latency and accuracy targets. We evaluate ApproxSSPS on Apache Spark Structured Streaming with real mobility data. We also compared ApproxSSPS against a state-of-the-art online adaptive processing system. Our extensive experiments prove that ApproxSSPS can fulfill latency and accuracy targets with varying sets of parameter configurations and load intensities (i.e., transient peaks in data loads versus slow arriving streams). Moreover, our results show that ApproxSSPS outperforms the baseline counterpart by significant magnitudes. In short, ApproxSSPS is a novel spatial data stream processing system that can deliver real accurate results in a timely manner, by dynamically specifying the limits on data samples.<\/jats:p>","DOI":"10.3390\/s21124160","type":"journal-article","created":{"date-parts":[[2021,6,17]],"date-time":"2021-06-17T11:20:26Z","timestamp":1623928826000},"page":"4160","update-policy":"https:\/\/doi.org\/10.3390\/mdpi_crossmark_policy","source":"Crossref","is-referenced-by-count":15,"title":["QoS-Aware Approximate Query Processing for Smart Cities Spatial Data Streams"],"prefix":"10.3390","volume":"21","author":[{"given":"Isam Mashhour","family":"Al Jawarneh","sequence":"first","affiliation":[{"name":"Dipartimento di Informatica\u2014Scienza e Ingegneria, University of Bologna, Viale del Risorgimento 2, 40136 Bologna, Italy"}],"role":[{"role":"author","vocabulary":"crossref"}]},{"ORCID":"https:\/\/orcid.org\/0000-0003-0992-7948","authenticated-orcid":false,"given":"Paolo","family":"Bellavista","sequence":"additional","affiliation":[{"name":"Dipartimento di Informatica\u2014Scienza e Ingegneria, University of Bologna, Viale del Risorgimento 2, 40136 Bologna, Italy"}],"role":[{"role":"author","vocabulary":"crossref"}]},{"ORCID":"https:\/\/orcid.org\/0000-0002-5107-1023","authenticated-orcid":false,"given":"Antonio","family":"Corradi","sequence":"additional","affiliation":[{"name":"Dipartimento di Informatica\u2014Scienza e Ingegneria, University of Bologna, Viale del Risorgimento 2, 40136 Bologna, Italy"}],"role":[{"role":"author","vocabulary":"crossref"}]},{"ORCID":"https:\/\/orcid.org\/0000-0001-9062-3647","authenticated-orcid":false,"given":"Luca","family":"Foschini","sequence":"additional","affiliation":[{"name":"Dipartimento di Informatica\u2014Scienza e Ingegneria, University of Bologna, Viale del Risorgimento 2, 40136 Bologna, Italy"}],"role":[{"role":"author","vocabulary":"crossref"}]},{"given":"Rebecca","family":"Montanari","sequence":"additional","affiliation":[{"name":"Dipartimento di Informatica\u2014Scienza e Ingegneria, University of Bologna, Viale del Risorgimento 2, 40136 Bologna, Italy"}],"role":[{"role":"author","vocabulary":"crossref"}]}],"member":"1968","published-online":{"date-parts":[[2021,6,17]]},"reference":[{"key":"ref_1","doi-asserted-by":"crossref","unstructured":"Aljawarneh, I.M., Bellavista, P., De Rolt, C.R., and Foschini, L. (2017). Dynamic Identification of Participatory Mobile Health Communities. Cloud Infrastructures, Services, and IoT Systems for Smart Cities, Springer.","DOI":"10.1007\/978-3-319-67636-4_22"},{"key":"ref_2","doi-asserted-by":"crossref","unstructured":"Al Jawarneh, I.M., Bellavista, P., Foschini, L., and Montanari, R. (2019, January 9\u201313). Spatial-Aware Approximate Big Data Stream Processing. Proceedings of the 2019 IEEE Global Communications Conference (GLOBECOM), Big Island, HI, USA.","DOI":"10.1109\/GLOBECOM38437.2019.9014291"},{"key":"ref_3","first-page":"1550147719853984","article-title":"Smart cities survey: Technologies, application domains and challenges for the cities of the future","volume":"15","author":"Mulero","year":"2019","journal-title":"Int. J. Distrib. Sensor Netw."},{"key":"ref_4","first-page":"95","article-title":"Spark: Cluster computing with working sets","volume":"10","author":"Zaharia","year":"2010","journal-title":"HotCloud"},{"key":"ref_5","first-page":"28","article-title":"Apache flink: Stream and batch processing in a single engine","volume":"36","author":"Carbone","year":"2015","journal-title":"Bull. IEEE Comput. Soc. Tech. Committee Data Eng."},{"key":"ref_6","doi-asserted-by":"crossref","unstructured":"Chen, X., Vigfusson, Y., Blough, D.M., Zheng, F., Wu, K.-L., and Hu, L. (2017, January 17\u201321). GOVERNOR: Smoother Stream Processing Through Smarter Backpressure. Proceedings of the 2017 IEEE International Conference on Autonomic Computing (ICAC), Columbus, OH, USA.","DOI":"10.1109\/ICAC.2017.31"},{"key":"ref_7","doi-asserted-by":"crossref","unstructured":"Al Jawarneh, I.M., Bellavista, P., Corradi, A., Foschini, L., and Montanari, R. (2020, January 14\u201316). Spatially Representative Online Big Data Sampling for Smart Cities. Proceedings of the 2020 IEEE 25th International Workshop on Computer Aided Modeling and Design of Communication Links and Networks (CAMAD), Virtual Conference, Pisa, Italy.","DOI":"10.1109\/CAMAD50429.2020.9209294"},{"key":"ref_8","doi-asserted-by":"crossref","first-page":"25123","DOI":"10.1109\/ACCESS.2019.2899825","article-title":"Online adaptive approximate stream processing with customized error control","volume":"7","author":"Wei","year":"2019","journal-title":"IEEE Access"},{"key":"ref_9","doi-asserted-by":"crossref","unstructured":"Aljawarneh, I.M., Bellavista, P., Corradi, A., Montanari, R., Foschini, L., and Zanotti, A. (2017, January 3\u20136). Efficient spark-based framework for big geospatial data query processing and analysis. Proceedings of the 2017 IEEE Symposium on Computers and Communications (ISCC), Heraklion, Crete, Greece.","DOI":"10.1109\/ISCC.2017.8024633"},{"key":"ref_10","unstructured":"Herbst, N.R., Kounev, S., and Reussner, R. (2013, January 26\u201328). Elasticity in cloud computing: What it is, and what it is not. Proceedings of the 10th International Conference on Autonomic Computing (ICAC 13), San Jose, CA, USA."},{"key":"ref_11","doi-asserted-by":"crossref","first-page":"559","DOI":"10.1007\/s10723-014-9314-7","article-title":"A Review of Auto-scaling Techniques for Elastic Applications in Cloud Environments","volume":"12","author":"Lozano","year":"2014","journal-title":"J. Grid Comput."},{"key":"ref_12","doi-asserted-by":"crossref","unstructured":"Al Jawarneh, I.M., Bellavista, P., Casimiro, F., Corradi, A., and Foschini, L. (2018, January 25\u201328). Cost-effective strategies for provisioning NoSQL storage services in support for industry 4.0. Proceedings of the 2018 IEEE Symposium on Computers and Communications (ISCC), Natal, Brazil.","DOI":"10.1109\/ISCC.2018.8538616"},{"key":"ref_13","doi-asserted-by":"crossref","first-page":"2437","DOI":"10.1109\/TNSM.2020.3034150","article-title":"Efficient QoS-Aware Spatial Join Processing for Scalable NoSQL Storage Frameworks","volume":"18","author":"Bellavista","year":"2021","journal-title":"IEEE Trans. Netw. Serv. Manag."},{"key":"ref_14","doi-asserted-by":"crossref","first-page":"990","DOI":"10.1007\/s10922-020-09549-6","article-title":"Big Spatial Data Management for the Internet of Things: A Survey","volume":"28","author":"Bellavista","year":"2020","journal-title":"J. Netw. Syst. Manag."},{"key":"ref_15","doi-asserted-by":"crossref","unstructured":"Ordonez-Ante, L., Van Seghbroeck, G., Wauters, T., Volckaert, B., and De Turck, F. (2020). EXPLORA: Interactive Querying of Multidimensional Data in the Context of Smart Cities. Sensors, 20.","DOI":"10.3390\/s20092737"},{"key":"ref_16","doi-asserted-by":"crossref","unstructured":"Ramnarayan, J., Mozafari, B., Wale, S., Menon, S., Kumar, N., Bhanawat, H., Chakraborty, S., Mahajan, Y., Mishra, R., and Bachhav, K. (July, January 26). Snappydata: A hybrid transactional analytical store built on spark. Proceedings of the 2016 International Conference on Management of Data, San Francisco, CA, USA.","DOI":"10.1145\/2882903.2899408"},{"key":"ref_17","doi-asserted-by":"crossref","unstructured":"Olma, M., Papapetrou, O., Appuswamy, R., and Ailamaki, A. (2019, January 8\u201311). Taster: Self-tuning, elastic and online approximate query processing. Proceedings of the 2019 IEEE 35th International Conference on Data Engineering (ICDE), Macau, China.","DOI":"10.1109\/ICDE.2019.00050"},{"key":"ref_18","doi-asserted-by":"crossref","unstructured":"Goiri, I., Bianchini, R., Nagarakatte, S., and Nguyen, T.D. (2015, January 14\u201318). Approxhadoop: Bringing approximations to mapreduce frameworks. Proceedings of the Twentieth International Conference on Architectural Support for Programming Languages and Operating Systems, Istanbul, Turkey.","DOI":"10.1145\/2694344.2694351"},{"key":"ref_19","doi-asserted-by":"crossref","unstructured":"Xie, D., Li, F., Yao, B., Li, G., Zhou, L., and Guo, M. (July, January 26). Simba: Efficient in-memory spatial analytics. Proceedings of the 2016 International Conference on Management of Data, San Francisco, CA, USA.","DOI":"10.1145\/2882903.2915237"},{"key":"ref_20","doi-asserted-by":"crossref","unstructured":"Eldawy, A., and Mokbel, M.F. (2015, January 13\u201317). Spatialhadoop: A mapreduce framework for spatial data. Proceedings of the 2015 IEEE 31st international conference on Data Engineering, Seoul, Korea.","DOI":"10.1109\/ICDE.2015.7113382"},{"key":"ref_21","doi-asserted-by":"crossref","unstructured":"Armbrust, M., Das, T., Torres, J., Yavuz, B., Zhu, S., Xin, R., Ghodsi, A., Stoica, I., and Zaharia, M. (2018, January 10\u201315). Structured Streaming: A Declarative API for Real-Time Applications in Apache Spark. Proceedings of the 2018 International Conference on Management of Data, Houston, TX, USA.","DOI":"10.1145\/3183713.3190664"},{"key":"ref_22","doi-asserted-by":"crossref","unstructured":"Zaharia, M., Das, T., Li, H., Hunter, T., Shenker, S., and Stoica, I. (2013, January 3\u20136). Discretized streams: Fault-tolerant streaming computation at scale. Proceedings of the twenty-fourth ACM Symposium on Operating Systems Principles, Farmington, PA, USA.","DOI":"10.1145\/2517349.2522737"},{"key":"ref_23","doi-asserted-by":"crossref","unstructured":"Lohr, S.L. (2019). Sampling: Design and Analysis, Chapman and Hall\/CRC.","DOI":"10.1201\/9780429296284"},{"key":"ref_24","doi-asserted-by":"crossref","unstructured":"Al Jawarneh, I.M., Bellavista, P., Corradi, A., Foschini, L., Montanari, R., and Zanotti, A. (2018, January 17\u201319). In-memory spatial-aware framework for processing proximity-alike queries in big spatial data. Proceedings of the 2018 IEEE 23rd International Workshop on Computer Aided Modeling and Design of Communication Links and Networks (CAMAD), Barcelona, Spain.","DOI":"10.1109\/CAMAD.2018.8514950"},{"key":"ref_25","doi-asserted-by":"crossref","unstructured":"Al Jawarneh, I.M., Bellavista, P., Corradi, A., Foschini, L., and Montanari, R. (2020, January 7\u201311). Locality-Preserving Spatial Partitioning for Geo Big Data Analytics in Main Memory Frameworks. Proceedings of the GLOBECOM 2020\u20132020 IEEE Global Communications Conference (Virtual Conference), Taipei, Taiwan.","DOI":"10.1109\/GLOBECOM42002.2020.9322544"},{"key":"ref_26","doi-asserted-by":"crossref","unstructured":"Hoeffding, W. (1994). Probability inequalities for sums of bounded random variables. The Collected Works of Wassily Hoeffding, Springer.","DOI":"10.1007\/978-1-4612-0865-5_26"},{"key":"ref_27","doi-asserted-by":"crossref","unstructured":"Wang, G., Chen, X., Zhang, F., Wang, Y., and Zhang, D. (2019, January 21\u201321). Experience: Understanding long-term evolving patterns of shared electric vehicle networks. Proceedings of the 25th Annual International Conference on Mobile Computing and Networking, Los Cabos, Mexico.","DOI":"10.1145\/3300061.3300132"},{"key":"ref_28","unstructured":"Allen, S.T., Jankowski, M., and Pathirana, P. (2015). Storm Applied: Strategies for Real-Time Event Processing, Manning Publications Co."},{"key":"ref_29","unstructured":"Jafarpour, H., Desai, R., and Guy, D. (2019, January 26\u201329). KSQL: Streaming SQL Engine for Apache Kafka. Proceedings of the 22nd International Conference on Extending Database Technology (EDBT), Lisbon, Portugal."},{"key":"ref_30","doi-asserted-by":"crossref","unstructured":"Arasu, A., Babcock, B., Babu, S., Cieslewicz, J., Datar, M., Ito, K., Motwani, R., Srivastava, U., and Widom, J. (2016). Stream: The stanford data stream management system. Data Stream Management, Springer.","DOI":"10.1007\/978-3-540-28608-0_16"}],"container-title":["Sensors"],"original-title":[],"language":"en","link":[{"URL":"https:\/\/www.mdpi.com\/1424-8220\/21\/12\/4160\/pdf","content-type":"unspecified","content-version":"vor","intended-application":"similarity-checking"}],"deposited":{"date-parts":[[2025,10,11]],"date-time":"2025-10-11T06:17:43Z","timestamp":1760163463000},"score":1,"resource":{"primary":{"URL":"https:\/\/www.mdpi.com\/1424-8220\/21\/12\/4160"}},"subtitle":[],"short-title":[],"issued":{"date-parts":[[2021,6,17]]},"references-count":30,"journal-issue":{"issue":"12","published-online":{"date-parts":[[2021,6]]}},"alternative-id":["s21124160"],"URL":"https:\/\/doi.org\/10.3390\/s21124160","relation":{},"ISSN":["1424-8220"],"issn-type":[{"value":"1424-8220","type":"electronic"}],"subject":[],"published":{"date-parts":[[2021,6,17]]}}}