{"status":"ok","message-type":"work","message-version":"1.0.0","message":{"indexed":{"date-parts":[[2026,8,28]],"date-time":"2026-08-28T16:55:41Z","timestamp":1787936141379,"version":"build-2784847793"},"reference-count":69,"publisher":"Institute of Electrical and Electronics Engineers (IEEE)","issue":"8","license":[{"start":{"date-parts":[[2021,8,1]],"date-time":"2021-08-01T00:00:00Z","timestamp":1627776000000},"content-version":"vor","delay-in-days":0,"URL":"https:\/\/ieeexplore.ieee.org\/Xplorehelp\/downloads\/license-information\/IEEE.html"},{"start":{"date-parts":[[2021,8,1]],"date-time":"2021-08-01T00:00:00Z","timestamp":1627776000000},"content-version":"am","delay-in-days":0,"URL":"https:\/\/ieeexplore.ieee.org\/Xplorehelp\/downloads\/license-information\/IEEE.html"},{"start":{"date-parts":[[2021,8,1]],"date-time":"2021-08-01T00:00:00Z","timestamp":1627776000000},"content-version":"stm-asf","delay-in-days":0,"URL":"https:\/\/doi.org\/10.15223\/policy-029"},{"start":{"date-parts":[[2021,8,1]],"date-time":"2021-08-01T00:00:00Z","timestamp":1627776000000},"content-version":"stm-asf","delay-in-days":0,"URL":"https:\/\/doi.org\/10.15223\/policy-037"}],"funder":[{"DOI":"10.13039\/100000001","name":"National Science Foundation","doi-asserted-by":"publisher","award":["OAC-1931363"],"award-info":[{"award-number":["OAC-1931363"]}],"id":[{"id":"10.13039\/100000001","id-type":"DOI","asserted-by":"publisher"}]},{"DOI":"10.13039\/100000001","name":"National Science Foundation","doi-asserted-by":"publisher","award":["ACI-1553685"],"award-info":[{"award-number":["ACI-1553685"]}],"id":[{"id":"10.13039\/100000001","id-type":"DOI","asserted-by":"publisher"}]},{"DOI":"10.13039\/100005825","name":"National Institute of Food and Agriculture","doi-asserted-by":"publisher","award":["COL0-FACT-2019"],"award-info":[{"award-number":["COL0-FACT-2019"]}],"id":[{"id":"10.13039\/100005825","id-type":"DOI","asserted-by":"publisher"}]},{"name":"Cochran Family Professorship"}],"content-domain":{"domain":[],"crossmark-restriction":false},"short-container-title":["IEEE Trans. Parallel Distrib. Syst."],"published-print":{"date-parts":[[2021,8,1]]},"DOI":"10.1109\/tpds.2021.3055265","type":"journal-article","created":{"date-parts":[[2021,1,28]],"date-time":"2021-01-28T20:34:42Z","timestamp":1611866082000},"page":"2005-2020","source":"Crossref","is-referenced-by-count":13,"title":["Pebbles: Leveraging Sketches for Processing Voluminous, High Velocity Data Streams"],"prefix":"10.1109","volume":"32","author":[{"ORCID":"https:\/\/orcid.org\/0000-0002-1375-4595","authenticated-orcid":false,"given":"Thilina","family":"Buddhika","sequence":"first","affiliation":[],"role":[{"vocabulary":"crossref","role":"author"}]},{"given":"Sangmi Lee","family":"Pallickara","sequence":"additional","affiliation":[],"role":[{"vocabulary":"crossref","role":"author"}]},{"given":"Shrideep","family":"Pallickara","sequence":"additional","affiliation":[],"role":[{"vocabulary":"crossref","role":"author"}]}],"member":"263","reference":[{"key":"ref39","article-title":"MQ telemetry transport (MQTT) v3.1 protocol specification","author":"locke","year":"0","journal-title":"IBM developerWorks"},{"key":"ref38","article-title":"Apache edgent: A community for accelerating analytics at the edge","year":"2016"},{"key":"ref33","doi-asserted-by":"publisher","DOI":"10.1145\/2882903.2882948"},{"key":"ref32","doi-asserted-by":"publisher","DOI":"10.1109\/BigDataCongress.2015.89"},{"key":"ref31","first-page":"516","article-title":"Lightweight temporal compression of microclimate datasets","author":"schoellhammer","year":"2004","journal-title":"Proc 29th Annu IEEE Int Conf Local Comput Netw"},{"key":"ref30","article-title":"miniLZO: Mini version of the LZO real-time data compression library","author":"oberhumer","year":"0"},{"key":"ref37","article-title":"AWS IoT greengrass: Bring local compute, messaging, data caching, sync, and ML inference capabilities to edge devices","year":"2019"},{"key":"ref36","article-title":"Sketch techniques for approximate query processing","author":"cormode","year":"0","journal-title":"Found Trends databases"},{"key":"ref35","doi-asserted-by":"publisher","DOI":"10.1016\/0167-6423(82)90012-0"},{"key":"ref34","doi-asserted-by":"publisher","DOI":"10.1016\/j.jalgor.2003.12.001"},{"key":"ref60","doi-asserted-by":"publisher","DOI":"10.1145\/2528412"},{"key":"ref62","article-title":"LZ4: Extremely fast compression algorithm","author":"collet","year":"2013"},{"key":"ref61","article-title":"JSR 335: Lambda expressions for the $\\mathrm {Java}^{TM}$ Java TM programming language","author":"process","year":"2012"},{"key":"ref63","doi-asserted-by":"publisher","DOI":"10.1145\/2408776.2408794"},{"key":"ref28","doi-asserted-by":"publisher","DOI":"10.1109\/MDM.2012.58"},{"key":"ref64","article-title":"Cisco kinetic edge & fog processing module","year":"2019"},{"key":"ref27","doi-asserted-by":"publisher","DOI":"10.1109\/BigData.2015.7363816"},{"key":"ref65","doi-asserted-by":"publisher","DOI":"10.1145\/3127479.3131621"},{"key":"ref66","doi-asserted-by":"publisher","DOI":"10.1145\/1007568.1007628"},{"key":"ref29","doi-asserted-by":"publisher","DOI":"10.1145\/1182807.1182834"},{"key":"ref67","doi-asserted-by":"publisher","DOI":"10.1145\/3035918.3035963"},{"key":"ref68","doi-asserted-by":"publisher","DOI":"10.14778\/1454159.1454225"},{"key":"ref69","first-page":"398","article-title":"Efficient computation of frequent and top-k elements in data streams","author":"metwally","year":"2005","journal-title":"Proc Int Conf Database Theory"},{"key":"ref2","article-title":"The North American Mesoscale forecast system","year":"2018"},{"key":"ref1","article-title":"Internet of Things (IoT) data continues to explode exponentially, who is using that data and how?","author":"stack","year":"2018"},{"key":"ref20","doi-asserted-by":"publisher","DOI":"10.1109\/TCC.2015.2424868"},{"key":"ref22","doi-asserted-by":"publisher","DOI":"10.1109\/ICFEC.2017.18"},{"key":"ref21","doi-asserted-by":"publisher","DOI":"10.1145\/2342509.2342513"},{"key":"ref24","first-page":"2043","article-title":"The spanish inquisition protocol–model based transmission reduction for wireless sensor networks","author":"goldsmith","year":"2010","journal-title":"Proc Sensors"},{"key":"ref23","doi-asserted-by":"publisher","DOI":"10.1145\/3156655.3156661"},{"key":"ref26","doi-asserted-by":"publisher","DOI":"10.1109\/ICSENS.2011.6127213"},{"key":"ref25","doi-asserted-by":"publisher","DOI":"10.1088\/0957-0233\/20\/7\/075204"},{"key":"ref50","article-title":"Notes on design and implementation of compressed bit vectors","author":"wu","year":"0"},{"key":"ref51","doi-asserted-by":"publisher","DOI":"10.1016\/j.datak.2009.08.006"},{"key":"ref59","first-page":"10","article-title":"Discretized streams: An efficient and fault-tolerant model for stream processing on large clusters","author":"zaharia","year":"2012","journal-title":"Proc 4th USENIX Conf Hot Topics Cloud Comput"},{"key":"ref58","article-title":"ACM DEBS 2014 grand challenge: Smart homes","year":"2014"},{"key":"ref57","doi-asserted-by":"publisher","DOI":"10.1023\/B:INRT.0000048490.99518.5c"},{"key":"ref56","doi-asserted-by":"publisher","DOI":"10.1109\/ICDE.2006.150"},{"key":"ref55","doi-asserted-by":"crossref","first-page":"405","DOI":"10.1145\/96749.98245","article-title":"Optimization for dynamic inverted index maintenance","author":"cutting","year":"1989","journal-title":"Proc Annu ACM SIGIR Conf Res Develop Inf Retrieval"},{"key":"ref54","doi-asserted-by":"publisher","DOI":"10.1145\/3035918.3064007"},{"key":"ref53","doi-asserted-by":"publisher","DOI":"10.1002\/spe.2325"},{"key":"ref52","doi-asserted-by":"publisher","DOI":"10.1016\/j.ipl.2010.05.018"},{"key":"ref10","doi-asserted-by":"publisher","DOI":"10.1093\/comjnl\/bxp035"},{"key":"ref11","doi-asserted-by":"publisher","DOI":"10.1109\/JSAC.2005.843554"},{"key":"ref40","doi-asserted-by":"publisher","DOI":"10.1109\/CTS.2012.6261020"},{"key":"ref12","doi-asserted-by":"publisher","DOI":"10.1145\/778415.778437"},{"key":"ref13","doi-asserted-by":"publisher","DOI":"10.1155\/2015\/468047"},{"key":"ref14","first-page":"25","article-title":"PAThH2iot: A holistic, distributed stream processing system","author":"michal\u00e1k","year":"2017","journal-title":"Proc Int Conf Cloud Comput Technol Sci"},{"key":"ref15","doi-asserted-by":"publisher","DOI":"10.1145\/1387663.1387671"},{"key":"ref16","doi-asserted-by":"publisher","DOI":"10.1109\/SEC.2016.17"},{"key":"ref17","author":"kleppmann","year":"2017","journal-title":"Designing Data-Intensive Applications The Big Ideas Behind Reliable Scalable and Maintainable Systems"},{"key":"ref18","article-title":"Questioning the lambda architecture","author":"kreps","year":"2014"},{"key":"ref19","doi-asserted-by":"publisher","DOI":"10.1109\/MPRV.2009.82"},{"key":"ref4","article-title":"Air data: Air quality data collected at outdoor monitors across the US","year":"2017"},{"key":"ref3","article-title":"MassDOT developers’ data sources","year":"2017"},{"key":"ref6","doi-asserted-by":"publisher","DOI":"10.1109\/ACCESS.2015.2437951"},{"key":"ref5","doi-asserted-by":"publisher","DOI":"10.1097\/CCM.0b013e31820a92c6"},{"key":"ref8","doi-asserted-by":"publisher","DOI":"10.1109\/SURV.2013.103013.00206"},{"key":"ref7","doi-asserted-by":"publisher","DOI":"10.1016\/j.snb.2015.03.028"},{"key":"ref49","doi-asserted-by":"publisher","DOI":"10.14778\/2536222.2536229"},{"key":"ref9","doi-asserted-by":"publisher","DOI":"10.1016\/j.future.2013.01.010"},{"key":"ref46","doi-asserted-by":"publisher","DOI":"10.1145\/3147.3165"},{"key":"ref45","doi-asserted-by":"publisher","DOI":"10.1214\/aoms\/1177728190"},{"key":"ref48","article-title":"VIRBs and sampling events from streams","author":"arfa","year":"2016"},{"key":"ref47","first-page":"607","article-title":"On biased reservoir sampling in the presence of stream evolution","author":"aggarwal","year":"2006","journal-title":"Proc 32nd Int Conf Very Large Data Bases"},{"key":"ref42","article-title":"Apache storm","year":"0"},{"key":"ref41","article-title":"Apache kafka: A distributed streaming platform","year":"0"},{"key":"ref44","doi-asserted-by":"publisher","DOI":"10.1214\/aoms\/1177704472"},{"key":"ref43","doi-asserted-by":"publisher","DOI":"10.1109\/IPDPS.2016.43"}],"container-title":["IEEE Transactions on Parallel and Distributed Systems"],"original-title":[],"link":[{"URL":"https:\/\/ieeexplore.ieee.org\/ielam\/71\/9360409\/9339879-aam.pdf","content-type":"application\/pdf","content-version":"am","intended-application":"syndication"},{"URL":"http:\/\/xplorestaging.ieee.org\/ielx7\/71\/9360409\/09339879.pdf?arnumber=9339879","content-type":"unspecified","content-version":"vor","intended-application":"similarity-checking"}],"deposited":{"date-parts":[[2023,10,19]],"date-time":"2023-10-19T13:26:12Z","timestamp":1697721972000},"score":1,"resource":{"primary":{"URL":"https:\/\/ieeexplore.ieee.org\/document\/9339879\/"}},"subtitle":[],"short-title":[],"issued":{"date-parts":[[2021,8,1]]},"references-count":69,"journal-issue":{"issue":"8"},"URL":"https:\/\/doi.org\/10.1109\/tpds.2021.3055265","relation":{},"ISSN":["1045-9219","1558-2183","2161-9883"],"issn-type":[{"value":"1045-9219","type":"print"},{"value":"1558-2183","type":"electronic"},{"value":"2161-9883","type":"electronic"}],"subject":[],"published":{"date-parts":[[2021,8,1]]}}}