{"status":"ok","message-type":"work","message-version":"1.0.0","message":{"indexed":{"date-parts":[[2025,10,11]],"date-time":"2025-10-11T01:54:20Z","timestamp":1760147660508,"version":"build-2065373602"},"reference-count":24,"publisher":"MDPI AG","issue":"3","license":[{"start":{"date-parts":[[2023,2,22]],"date-time":"2023-02-22T00:00:00Z","timestamp":1677024000000},"content-version":"vor","delay-in-days":0,"URL":"https:\/\/creativecommons.org\/licenses\/by\/4.0\/"}],"content-domain":{"domain":[],"crossmark-restriction":false},"short-container-title":["IJGI"],"abstract":"<jats:p>The availability of geodata with high spatial and temporal resolution is increasing steadily. Often, these data are continuously generated by distributed sensor networks and provided as geodata streams. Geostatistical analysis methods, such as spatiotemporal autocorrelation, have thus far been applied primarily to historized data. As such, the advantages of continuous and up-to-date acquisition of geodata have not yet been transferred to the analysis phase. At the same time, open-source frameworks for distributed stream processing have been developed into powerful real-time data processing tools. In this paper a methodology is developed to apply analyses of spatiotemporal autocorrelation directly to geodata streams through a distributed streaming process using open-source software frameworks. For this purpose, we adapt the extended Moran\u2019s I index for continuous and up-to-date computation, then apply it to simulated geospatial data streams of recorded taxi trip data. Various application scenarios for the developed methodology are tested and compared on a distributed computing cluster. The results show that the developed methodology can provide geostatistical analysis results in real time. This research demonstrates how modern datastream processing technologies have the potential to significantly advance the way geostatistical analysis can be performed and used in the future.<\/jats:p>","DOI":"10.3390\/ijgi12030087","type":"journal-article","created":{"date-parts":[[2023,2,22]],"date-time":"2023-02-22T05:01:32Z","timestamp":1677042092000},"page":"87","update-policy":"https:\/\/doi.org\/10.3390\/mdpi_crossmark_policy","source":"Crossref","is-referenced-by-count":9,"title":["Geostatistics on Real-Time Geodata Streams\u2014An Extended Spatiotemporal Moran\u2019s I Index with Distributed Stream Processing Technologies"],"prefix":"10.3390","volume":"12","author":[{"ORCID":"https:\/\/orcid.org\/0000-0002-3722-5284","authenticated-orcid":false,"given":"Thomas","family":"Lemmerz","sequence":"first","affiliation":[{"name":"Geodetic Institute and Chair for Computing in Civil Engineering & Geo Information Systems, RWTH Aachen University, 52074 Aachen, Germany"}],"role":[{"role":"author","vocabulary":"crossref"}]},{"ORCID":"https:\/\/orcid.org\/0000-0001-7995-8593","authenticated-orcid":false,"given":"Stefan","family":"Herl\u00e9","sequence":"additional","affiliation":[{"name":"Geodetic Institute and Chair for Computing in Civil Engineering & Geo Information Systems, RWTH Aachen University, 52074 Aachen, Germany"}],"role":[{"role":"author","vocabulary":"crossref"}]},{"ORCID":"https:\/\/orcid.org\/0000-0002-5700-8818","authenticated-orcid":false,"given":"J\u00f6rg","family":"Blankenbach","sequence":"additional","affiliation":[{"name":"Geodetic Institute and Chair for Computing in Civil Engineering & Geo Information Systems, RWTH Aachen University, 52074 Aachen, Germany"}],"role":[{"role":"author","vocabulary":"crossref"}]}],"member":"1968","published-online":{"date-parts":[[2023,2,22]]},"reference":[{"key":"ref_1","doi-asserted-by":"crossref","first-page":"166","DOI":"10.1080\/10095020.2019.1643609","article-title":"Measuring spatio-temporal autocorrelation in time series data of collective human mobility","volume":"22","author":"Gao","year":"2019","journal-title":"Geo-Spat. Inf. Sci."},{"key":"ref_2","doi-asserted-by":"crossref","first-page":"389","DOI":"10.1007\/s10109-011-0149-5","article-title":"Spatio-temporal autocorrelation of road network data","volume":"14","author":"Cheng","year":"2012","journal-title":"J. Geogr. Syst."},{"key":"ref_3","doi-asserted-by":"crossref","first-page":"851","DOI":"10.1080\/13658816.2019.1667501","article-title":"Spatio-temporal regression kriging for modelling urban NO 2 concentrations","volume":"34","author":"Osei","year":"2020","journal-title":"Int. J. Geogr. Inf. Sci."},{"key":"ref_4","doi-asserted-by":"crossref","first-page":"22","DOI":"10.1145\/2826686.2826691","article-title":"Real-Time Sensor Data Streams","volume":"7","author":"Nittel","year":"2015","journal-title":"SIGSPATIAL Spec."},{"key":"ref_5","doi-asserted-by":"crossref","first-page":"17","DOI":"10.1093\/biomet\/37.1-2.17","article-title":"Notes on Continuous Stochastic Phenomena","volume":"37","author":"Moran","year":"1950","journal-title":"Biometrika"},{"key":"ref_6","unstructured":"Cliff, A., and Ord, J.K. (1973). Monographs in Spatial and Environmental Systems Analysis, Pion."},{"key":"ref_7","doi-asserted-by":"crossref","first-page":"93","DOI":"10.1111\/j.1538-4632.1995.tb00338.x","article-title":"Local Indicators of Spatial Association-LISA","volume":"27","author":"Anselin","year":"1995","journal-title":"Geogr. Anal."},{"key":"ref_8","unstructured":"Liu, T., and Lu, D. (2012, January 3\u20135). The application and development of IOT. Proceedings of the 2012 International Symposium on Information Technologies in Medicine and Education, Hokodate, Hokkaido, Japan."},{"key":"ref_9","unstructured":"Herl\u00e9, S. (2019). A GeoEvent-Driven Architecture Based on GeoMQTT for the Geospatial IoT. [Ph.D. Thesis, Rheinisch-Westf\u00e4lische Technische Hochschule Aachen]."},{"key":"ref_10","unstructured":"Liu, X., Dastjerdi, A.V., and Buyya, R. (2016). Internet of Things, Elsevier."},{"key":"ref_11","unstructured":"Lorkowski, P., and Brinkhoff, T. (2015). Proceedings of EnviroInfo and ICT for Sustainability 2015, Atlantis Press. Advances in Computer Science Research."},{"key":"ref_12","unstructured":"Kazemitabar, S.J. (2013, January 5). Spatiotemporal transformation of social media geostreams. Proceedings of the 4th ACM SIGSPATIAL International Workshop on GeoStreaming, Orlando, FL, USA."},{"key":"ref_13","doi-asserted-by":"crossref","unstructured":"Lee, J., Liu, Y., and Yu, L. (2011, January 1). SGST: An Open Source Semantic Geostreaming Toolkit. Proceedings of the 2nd ACM SIGSPATIAL International Workshop on GeoStreaming, IWGS \u201911, Chicago, IL, USA.","DOI":"10.1145\/2064959.2064964"},{"key":"ref_14","doi-asserted-by":"crossref","unstructured":"Laska, M., Herle, S., Klamma, R., and Blankenbach, J. (2018). A Scalable Architecture for Real-Time Stream Processing of Spatiotemporal IoT Stream Data\u2014Performance Analysis on the Example of Map Matching. ISPRS Int. J. Geo-Inf., 7.","DOI":"10.3390\/ijgi7070238"},{"key":"ref_15","doi-asserted-by":"crossref","first-page":"134","DOI":"10.1016\/j.cageo.2016.03.004","article-title":"Stream Kriging: Incremental and recursive ordinary Kriging over spatiotemporal data streams","volume":"90","author":"Zhong","year":"2016","journal-title":"Comput. Geosci."},{"key":"ref_16","doi-asserted-by":"crossref","unstructured":"Bessis, N., and Dobre, C. (2014). Big Data and Internet of Things: A Roadmap for Smart Environments, Springer International Publishing.","DOI":"10.1007\/978-3-319-05029-4"},{"key":"ref_17","doi-asserted-by":"crossref","unstructured":"Hueske, F., and Kalavri, V. (2019). Stream Processing with Apache Flink: Fundamentals, Implementation, and Operation of Streaming Applications, O\u2019Reilly Media. [1st ed.].","DOI":"10.1007\/978-3-319-77525-8_303"},{"key":"ref_18","unstructured":"Anselin, L., Unwin, D.J., Scholten, H.J., and Fischer, M.M. The Moran Scatterplot as an ESDA Tool to Assess Local Instability in Spatial Association. Proceedings of the Spatial Analytical Perspectives on GIS."},{"key":"ref_19","unstructured":"Gorasiya, D. (2019). Comparison of Open-Source Data Stream Processing Engines: Spark Streaming, Flink and Storm, National College of Ireland (NCI). Technical Report."},{"key":"ref_20","doi-asserted-by":"crossref","unstructured":"Hesse, G., and Lorenz, M. (2015, January 14\u201317). Conceptual Survey on Data Stream Processing Systems. Proceedings of the 2015 IEEE 21st International Conference on Parallel and Distributed Systems (ICPADS), Melbourne, VIC, Australia.","DOI":"10.1109\/ICPADS.2015.106"},{"key":"ref_21","doi-asserted-by":"crossref","unstructured":"Lopez, M.A., Lobato, A.G.P., and Duarte, O.C.M.B. (2016, January 4\u20138). A Performance Comparison of Open-Source Stream Processing Platforms. Proceedings of the 2016 IEEE Global Communications Conference (GLOBECOM), Washington, DC, USA.","DOI":"10.1109\/GLOCOM.2016.7841533"},{"key":"ref_22","unstructured":"Sharvari, T., and Sowmya Nag, K. (2019). A study on Modern Messaging Systems- Kafka, RabbitMQ and NATS Streaming. arXiv."},{"key":"ref_23","unstructured":"(2022, September 30). New York City Taxi and Limousine Commission. TLC Trip Record Data, 2018. New York City Taxi and Limousine Commission Website, Available online: https:\/\/www1.nyc.gov\/site\/tlc\/about\/tlc-trip-record-data.page."},{"key":"ref_24","doi-asserted-by":"crossref","unstructured":"Karimov, J., Rabl, T., Katsifodimos, A., Samarev, R., Heiskanen, H., and Markl, V. (2018, January 16\u201319). Benchmarking Distributed Stream Data Processing Systems. Proceedings of the 2018 IEEE 34th International Conference on Data Engineering (ICDE), Paris, France.","DOI":"10.1109\/ICDE.2018.00169"}],"container-title":["ISPRS International Journal of Geo-Information"],"original-title":[],"language":"en","link":[{"URL":"https:\/\/www.mdpi.com\/2220-9964\/12\/3\/87\/pdf","content-type":"unspecified","content-version":"vor","intended-application":"similarity-checking"}],"deposited":{"date-parts":[[2025,10,10]],"date-time":"2025-10-10T18:39:10Z","timestamp":1760121550000},"score":1,"resource":{"primary":{"URL":"https:\/\/www.mdpi.com\/2220-9964\/12\/3\/87"}},"subtitle":[],"short-title":[],"issued":{"date-parts":[[2023,2,22]]},"references-count":24,"journal-issue":{"issue":"3","published-online":{"date-parts":[[2023,3]]}},"alternative-id":["ijgi12030087"],"URL":"https:\/\/doi.org\/10.3390\/ijgi12030087","relation":{},"ISSN":["2220-9964"],"issn-type":[{"type":"electronic","value":"2220-9964"}],"subject":[],"published":{"date-parts":[[2023,2,22]]}}}