{"status":"ok","message-type":"work","message-version":"1.0.0","message":{"indexed":{"date-parts":[[2025,10,28]],"date-time":"2025-10-28T03:16:46Z","timestamp":1761621406364,"version":"build-2065373602"},"reference-count":36,"publisher":"MDPI AG","issue":"10","license":[{"start":{"date-parts":[[2018,9,27]],"date-time":"2018-09-27T00:00:00Z","timestamp":1538006400000},"content-version":"vor","delay-in-days":0,"URL":"https:\/\/creativecommons.org\/licenses\/by\/4.0\/"}],"funder":[{"DOI":"10.13039\/501100003725","name":"National Research Foundation of Korea","doi-asserted-by":"publisher","award":["NRF-2017R1D1A1A09000706"],"award-info":[{"award-number":["NRF-2017R1D1A1A09000706"]}],"id":[{"id":"10.13039\/501100003725","id-type":"DOI","asserted-by":"publisher"}]},{"DOI":"10.13039\/501100003665","name":"National IT Industry Promotion Agency","doi-asserted-by":"publisher","award":["S0607-18-1003"],"award-info":[{"award-number":["S0607-18-1003"]}],"id":[{"id":"10.13039\/501100003665","id-type":"DOI","asserted-by":"publisher"}]}],"content-domain":{"domain":[],"crossmark-restriction":false},"short-container-title":["Sensors"],"abstract":"<jats:p>The new standard oneM2M (one machine-to-machine) aims to standardize the architecture and protocols of Internet of Things (IoT) middleware for better interoperability. Although the standard seems promising, it lacks several features for efficiently searching and retrieving IoT data which satisfy users\u2019 intentions. In this paper, we design and develop a oneM2M-based query engine, called OMQ, that provides a real-time processing over IoT data streams. For this purpose, we define a query language which enables users to retrieve IoT data from data sources using JavaScript Object Notation (JSON). We also propose efficient query processing algorithms which utilizes the oneM2M architecture consisting of two nodes: (1) the IoT node and (2) the infrastructure node. IoT nodes of OMQ are mainly sensor devices execute user queries the aggregate, transform and filter operators, whereas the infrastructure node handles the join operator of user queries. Since the query processing algorithms are implemented as the hybrid infrastructure-edge processing, user queries can be executed efficiently in each IoT node rather than only in the infrastructure node. Thus, our OMQ system reduces the query processing time and the network bandwidth. We conducted a comprehensive evaluation of OMQ using a real and a synthetic data set. Experimental results demonstrate the feasibility and efficiency of OMQ system for executing queries and transferring data from each IoT node.<\/jats:p>","DOI":"10.3390\/s18103253","type":"journal-article","created":{"date-parts":[[2018,9,28]],"date-time":"2018-09-28T02:54:54Z","timestamp":1538103294000},"page":"3253","update-policy":"https:\/\/doi.org\/10.3390\/mdpi_crossmark_policy","source":"Crossref","is-referenced-by-count":8,"title":["A oneM2M-Based Query Engine for Internet of Things (IoT) Data Streams"],"prefix":"10.3390","volume":"18","author":[{"given":"Putu Wiramaswara","family":"Widya","sequence":"first","affiliation":[{"name":"Department of Big Data, Pusan National University, Busan 46241, Korea"}]},{"ORCID":"https:\/\/orcid.org\/0000-0003-2196-6536","authenticated-orcid":false,"given":"Yoga","family":"Yustiawan","sequence":"additional","affiliation":[{"name":"Department of Big Data, Pusan National University, Busan 46241, Korea"}]},{"ORCID":"https:\/\/orcid.org\/0000-0002-8207-9415","authenticated-orcid":false,"given":"Joonho","family":"Kwon","sequence":"additional","affiliation":[{"name":"School of Computer Science and Engineering, Pusan National University, Busan 46241, Korea"}]}],"member":"1968","published-online":{"date-parts":[[2018,9,27]]},"reference":[{"key":"ref_1","doi-asserted-by":"crossref","first-page":"1645","DOI":"10.1016\/j.future.2013.01.010","article-title":"Internet of Things (IoT): A vision, architectural elements, and future directions","volume":"29","author":"Gubbi","year":"2013","journal-title":"Future Gener. Comput. Syst."},{"key":"ref_2","doi-asserted-by":"crossref","first-page":"291","DOI":"10.1016\/j.jksuci.2016.10.003","article-title":"A survey on Internet of Things architectures","volume":"30","author":"Ray","year":"2018","journal-title":"J. King Saud Univ. Comput. Inform. Sci."},{"key":"ref_3","doi-asserted-by":"crossref","unstructured":"Thakur, A., Malekian, R., and Bogatinoska, D.C. (2017). Internet of Things Based Solutions for Road Safety and Traffic Management in Intelligent Transportation Systems. International Conference on ICT Innovations, Springer.","DOI":"10.1007\/978-3-319-67597-8_5"},{"key":"ref_4","first-page":"1","article-title":"Internet of Things Based Smart Hospital System Using Arduino Mega","volume":"5","author":"Singh","year":"2017","journal-title":"i-Manag. J. Comput. Sci."},{"key":"ref_5","doi-asserted-by":"crossref","unstructured":"Jo, B., and Baloch, Z. (2017). Internet of things-based arduino intelligent monitoring and cluster analysis of seasonal variation in physicochemical parameters of Jungnangcheon, an urban stream. Water, 9.","DOI":"10.3390\/w9030220"},{"key":"ref_6","doi-asserted-by":"crossref","unstructured":"Sowe, S.K., Kimata, T., Dong, M., and Zettsu, K. (2014, January 21\u201325). Managing heterogeneous sensor data on a big data platform: IoT services for data-intensive science. Proceedings of the 2014 IEEE 38th International Computer Software and Applications Conference Workshops (COMPSACW), Vasteras, Sweden.","DOI":"10.1109\/COMPSACW.2014.52"},{"key":"ref_7","doi-asserted-by":"crossref","first-page":"15582","DOI":"10.3390\/s131115582","article-title":"Data Management for the Internet of Things: Design Primitives and Solution","volume":"13","author":"Hayajneh","year":"2013","journal-title":"Sensors"},{"key":"ref_8","doi-asserted-by":"crossref","first-page":"70","DOI":"10.1109\/JIOT.2015.2498900","article-title":"Middleware for Internet of Things: A Survey","volume":"3","author":"Razzaque","year":"2016","journal-title":"Internet Things J."},{"key":"ref_9","first-page":"1","article-title":"IoT middleware: A survey on issues and enabling technologies","volume":"4","author":"Ngu","year":"2017","journal-title":"Internet Things J."},{"key":"ref_10","doi-asserted-by":"crossref","first-page":"54","DOI":"10.1109\/MS.2017.2","article-title":"Enabling IoT ecosystems through platform interoperability","volume":"34","author":"Schmid","year":"2017","journal-title":"Software"},{"key":"ref_11","doi-asserted-by":"crossref","first-page":"20","DOI":"10.1109\/MWC.2014.6845045","article-title":"Toward a standardized common M2M service layer platform: Introduction to oneM2M","volume":"21","author":"Swetina","year":"2014","journal-title":"Wirel. Commun."},{"key":"ref_12","doi-asserted-by":"crossref","first-page":"1079","DOI":"10.1016\/j.procs.2014.05.536","article-title":"OM2M: Extensible ETSI-compliant M2M service platform with self-configuration capability","volume":"32","author":"Alaya","year":"2014","journal-title":"Procedia Comput. Sci."},{"key":"ref_13","doi-asserted-by":"crossref","unstructured":"Kim, J., Choi, S.C., Ahn, I.Y., Sung, N.M., and Yun, J. (2016). From WSN towards WoT: Open API Scheme Based on oneM2M Platforms. Sensors, 16.","DOI":"10.3390\/s16101645"},{"key":"ref_14","doi-asserted-by":"crossref","unstructured":"Sicari, S., Rizzardi, A., Coen-Porisini, A., Grieco, L.A., and Monteil, T. (2015, January 7\u201310). Secure OM2M service platform. Proceedings of the 2015 IEEE International Conference on Autonomic Computing (ICAC), Grenoble, France.","DOI":"10.1109\/ICAC.2015.59"},{"key":"ref_15","first-page":"36","article-title":"HANDYPIA Platform and Service Technology for Semantic IoT Service","volume":"3","author":"Lee","year":"2014","journal-title":"Smart Media"},{"key":"ref_16","doi-asserted-by":"crossref","first-page":"42","DOI":"10.1109\/MCOM.2015.7355583","article-title":"Toward enhanced data exchange capabilities for the oneM2M service platform","volume":"53","author":"Glaab","year":"2015","journal-title":"Commun. Mag."},{"key":"ref_17","doi-asserted-by":"crossref","first-page":"107","DOI":"10.1145\/1327452.1327492","article-title":"MapReduce: Simplified data processing on large clusters","volume":"51","author":"Dean","year":"2008","journal-title":"Commun. ACM"},{"key":"ref_18","doi-asserted-by":"crossref","unstructured":"Shanahan, J.G., and Dai, L. (2015, January 10\u201313). Large scale distributed data science using Apache Spark. Proceedings of the International Conference on Knowledge Discovery and Data Mining (SIGKDD), Sydney, Australia.","DOI":"10.1145\/2783258.2789993"},{"key":"ref_19","doi-asserted-by":"crossref","unstructured":"Toshniwal, A., Taneja, S., Shukla, A., Ramasamy, K., Patel, J.M., Kulkarni, S., Jackson, J., Gade, K., Maosong, F., and Donham, J. (2014, January 22\u201327). Storm@ twitter. Proceedings of the International conference on Management of data (SIGMOD), Snowbird, UT, USA.","DOI":"10.1145\/2588555.2595641"},{"key":"ref_20","doi-asserted-by":"crossref","unstructured":"Chowdhery, A., Levorato, M., Burago, I., and Baidya, S. (2018). Urban IoT Edge Analytics. Fog Computing in the Internet of Things, Springer.","DOI":"10.1007\/978-3-319-57639-8_6"},{"key":"ref_21","unstructured":"Mo, S., Chen, H., Zhang, X., and Li, C. (, January 14\u201316). TinyQP: A query processing system in wireless sensor networks. Proceedings of the International Conference on Web-Age Information Management, Beidaihe, China."},{"key":"ref_22","doi-asserted-by":"crossref","unstructured":"Al-Hoqani, N., Yang, S.H., Fiadzeawu, D.P., and Mcquillan, R.J. (2017, January 19\u201322). In-Network On-Demand Query-Based Sensing System for Wireless Sensor Networks. Proceedings of the Wireless Communications and Networking Conference (WCNC), San Francisco, CA, USA.","DOI":"10.1109\/WCNC.2017.7925597"},{"key":"ref_23","doi-asserted-by":"crossref","first-page":"1013","DOI":"10.1016\/j.jnca.2011.12.006","article-title":"Real-time data management on wireless sensor networks: A survey","volume":"35","author":"Diallo","year":"2012","journal-title":"J. Netw. Comput. Appl."},{"key":"ref_24","doi-asserted-by":"crossref","first-page":"641","DOI":"10.1016\/j.future.2017.02.014","article-title":"Exploiting smart e-health gateways at the edge of healthcare internet-of-things: A fog computing approach","volume":"78","author":"Rahmani","year":"2017","journal-title":"Future Gener. Comput. Syst."},{"key":"ref_25","doi-asserted-by":"crossref","unstructured":"Aberer, K., Hauswirth, M., and Salehi, A. (2007, January 1). Infrastructure for Data Processing in Large-Scale Interconnected Sensor Networks. Proceedings of the International Conference on Mobile Data Management, Mannheim, Germany.","DOI":"10.1109\/MDM.2007.36"},{"key":"ref_26","doi-asserted-by":"crossref","unstructured":"Mueller, R., Rellermeyer, J.S., Duller, M., and Alonso, G. (2007, January 8\u201311). A generic platform for sensor network applications. Proceedings of the International Conference on Mobile Adhoc and Sensor Systems (MAAS), Pisa, Italy.","DOI":"10.1109\/MOBHOC.2007.4428693"},{"key":"ref_27","unstructured":"Cao, H., Wachowicz, M., and Cha, S. (2017). Developing an edge analytics platform for analyzing real-time transit data streams. arXiv."},{"key":"ref_28","doi-asserted-by":"crossref","first-page":"4287834","DOI":"10.1155\/2016\/4287834","article-title":"A Stream processing system for multisource heterogeneous sensor data","volume":"2016","author":"Hu","year":"2016","journal-title":"J. Sens."},{"key":"ref_29","unstructured":"Govindarajan, N., Simmhan, Y., Jamadagni, N., and Misra, P. (2014, January 22\u201327). Event processing across edge and the cloud for internet of things applications. Proceedings of the International Conference on Management of Data, Snowbird, UT, USA."},{"key":"ref_30","unstructured":"Ghosh, R., and Simmhan, Y. (2016). Distributed Scheduling of Event Analytics across Edge and Cloud. arXiv."},{"key":"ref_31","doi-asserted-by":"crossref","unstructured":"Ravindra, P., Khochare, A., Reddy, S.P., Sharma, S., Varshney, P., and Simmhan, Y. (2017). ECHO: An Adaptive Orchestration Platform for Hybrid Dataflows across Cloud and Edge. arXiv.","DOI":"10.1007\/978-3-319-69035-3_28"},{"key":"ref_32","unstructured":"oneM2M Partners Type\u00a01 (2018, August 27). Functional Architecture (TS-0001-V1.6.1). Available online: http:\/\/www.onem2m.org\/images\/files\/deliverables\/TS-0001-Functional_Architecture-V1_6_1.pdf."},{"key":"ref_33","unstructured":"oneM2M Partners Type\u00a01 (2018, August 27). Service Layer Core Protocol Specification (TS-0001-V1.6.1). Available online: https:\/\/www.onem2m.org\/images\/files\/deliverables\/UpdateRelease1\/TS-0004-Service_Layer_Core_Protocol-V1_6_0.zip."},{"key":"ref_34","unstructured":"Widya, P.W., Yustiawan, Y., and Kwon, J. (2018, September 10). OMQ: An oneM2M-Based Query Engine System. Available online: https:\/\/github.com\/yogagm\/OMQ-onem2m-queryengine."},{"key":"ref_35","doi-asserted-by":"crossref","first-page":"1086","DOI":"10.1109\/ACCESS.2016.2541999","article-title":"Citypulse: Large scale data analytics framework for smart cities","volume":"4","author":"Puiu","year":"2016","journal-title":"IEEE Access"},{"key":"ref_36","doi-asserted-by":"crossref","unstructured":"Jurgelionis, A., Laulajainen, J., Hirvonen, M., and Wang, A.I. (July, January 4). An Empirical Study of NetEm Network Emulation Functionalities. Proceedings of the 20th International Conference on Computer Communications and Networks, ICCCN 2011, Maui, HI, USA.","DOI":"10.1109\/ICCCN.2011.6005933"}],"container-title":["Sensors"],"original-title":[],"language":"en","link":[{"URL":"https:\/\/www.mdpi.com\/1424-8220\/18\/10\/3253\/pdf","content-type":"unspecified","content-version":"vor","intended-application":"similarity-checking"}],"deposited":{"date-parts":[[2025,10,11]],"date-time":"2025-10-11T15:22:49Z","timestamp":1760196169000},"score":1,"resource":{"primary":{"URL":"https:\/\/www.mdpi.com\/1424-8220\/18\/10\/3253"}},"subtitle":[],"short-title":[],"issued":{"date-parts":[[2018,9,27]]},"references-count":36,"journal-issue":{"issue":"10","published-online":{"date-parts":[[2018,10]]}},"alternative-id":["s18103253"],"URL":"https:\/\/doi.org\/10.3390\/s18103253","relation":{},"ISSN":["1424-8220"],"issn-type":[{"type":"electronic","value":"1424-8220"}],"subject":[],"published":{"date-parts":[[2018,9,27]]}}}