{"status":"ok","message-type":"work","message-version":"1.0.0","message":{"indexed":{"date-parts":[[2026,4,23]],"date-time":"2026-04-23T11:01:08Z","timestamp":1776942068602,"version":"3.51.4"},"reference-count":26,"publisher":"Cambridge University Press (CUP)","issue":"5","license":[{"start":{"date-parts":[[2021,9,23]],"date-time":"2021-09-23T00:00:00Z","timestamp":1632355200000},"content-version":"unspecified","delay-in-days":22,"URL":"https:\/\/www.cambridge.org\/core\/terms"}],"content-domain":{"domain":["cambridge.org"],"crossmark-restriction":true},"short-container-title":["Theory and Practice of Logic Programming"],"published-print":{"date-parts":[[2021,9]]},"abstract":"<jats:title>Abstract<\/jats:title><jats:p>We introduce a novel logic-based system for reasoning over data streams, which relies on a framework enabling a tight, fine-tuned interaction between <jats:italic>Apache Flink<\/jats:italic> and the <jats:inline-formula><jats:alternatives><jats:inline-graphic xmlns:xlink=\"http:\/\/www.w3.org\/1999\/xlink\" mime-subtype=\"png\" xlink:href=\"S147106842100034X_inline1.png\"\/><jats:tex-math>\n$${{\\mathcal I}^2}$$\n<\/jats:tex-math><\/jats:alternatives><\/jats:inline-formula>-<jats:italic>DLV<\/jats:italic> system. The architecture allows to take advantage from both the powerful distributed stream processing capabilities of <jats:italic>Flink<\/jats:italic> and the incremental reasoning capabilities of <jats:inline-formula><jats:alternatives><jats:inline-graphic xmlns:xlink=\"http:\/\/www.w3.org\/1999\/xlink\" mime-subtype=\"png\" xlink:href=\"S147106842100034X_inline1.png\"\/><jats:tex-math>\n$${{\\mathcal I}^2}$$\n<\/jats:tex-math><\/jats:alternatives><\/jats:inline-formula>-<jats:italic>DLV<\/jats:italic>, based on overgrounding techniques. Besides the system architecture, we illustrate the supported input language and its modeling capabilities, and discuss the results of an experimental activity aimed at assessing the viability of the approach.<\/jats:p>","DOI":"10.1017\/s147106842100034x","type":"journal-article","created":{"date-parts":[[2021,9,23]],"date-time":"2021-09-23T06:43:09Z","timestamp":1632379389000},"page":"610-628","update-policy":"https:\/\/doi.org\/10.1017\/policypage","source":"Crossref","is-referenced-by-count":11,"title":["I-DLV-sr: A Stream Reasoning System based on I-DLV"],"prefix":"10.1017","volume":"21","author":[{"ORCID":"https:\/\/orcid.org\/0000-0002-0866-0834","authenticated-orcid":false,"given":"FRANCESCO","family":"CALIMERI","sequence":"first","affiliation":[],"role":[{"role":"author","vocabulary":"crossref"}]},{"ORCID":"https:\/\/orcid.org\/0000-0003-3323-9328","authenticated-orcid":false,"given":"MARCO","family":"MANNA","sequence":"additional","affiliation":[],"role":[{"role":"author","vocabulary":"crossref"}]},{"given":"ELENA","family":"MASTRIA","sequence":"additional","affiliation":[],"role":[{"role":"author","vocabulary":"crossref"}]},{"given":"MARIA CONCETTA","family":"MORELLI","sequence":"additional","affiliation":[],"role":[{"role":"author","vocabulary":"crossref"}]},{"ORCID":"https:\/\/orcid.org\/0000-0002-8036-5709","authenticated-orcid":false,"given":"SIMONA","family":"PERRI","sequence":"additional","affiliation":[],"role":[{"role":"author","vocabulary":"crossref"}]},{"ORCID":"https:\/\/orcid.org\/0000-0002-6418-7711","authenticated-orcid":false,"given":"JESSICA","family":"ZANGARI","sequence":"additional","affiliation":[],"role":[{"role":"author","vocabulary":"crossref"}]}],"member":"56","published-online":{"date-parts":[[2021,9,23]]},"reference":[{"key":"S147106842100034X_ref11","first-page":"28","article-title":"Apache flink: Stream and batch processing in a single engine","volume":"4","author":"Carbone","year":"2015","journal-title":"IEEE Data Engineering Bulletin 38"},{"key":"S147106842100034X_ref19","volume-title":"O\u2019Reilly Media","author":"Hueske","year":"2019"},{"key":"S147106842100034X_ref12","doi-asserted-by":"publisher","DOI":"10.3233\/DS-170006"},{"key":"S147106842100034X_ref3","doi-asserted-by":"crossref","unstructured":"Beck, H. , Bierbaumer, B. , Dao-Tran, M. , Eiter, T. , Hellwagner, H. and Schekotihin, K. 2017. Stream reasoning-based control of caching strategies in CCN routers. In IEEE International Conference on Communications, ICC 2017, Paris, France, May 21\u201325, 2017. IEEE, 1\u20136.","DOI":"10.1109\/ICC.2017.7996762"},{"key":"S147106842100034X_ref1","doi-asserted-by":"publisher","DOI":"10.1142\/S1793351X10000936"},{"key":"S147106842100034X_ref6","doi-asserted-by":"publisher","DOI":"10.1007\/s13218-018-0537-9"},{"key":"S147106842100034X_ref14","doi-asserted-by":"publisher","DOI":"10.1017\/S1471068419000309"},{"key":"S147106842100034X_ref21","doi-asserted-by":"crossref","unstructured":"Karimov, J. , Rabl, T. , Katsifodimos, A. , Samarev, R. , Heiskanen, H. and Markl, V. 2018. Benchmarking distributed stream data processing systems. In 34th IEEE International Conference on Data Engineering, ICDE 2018, Paris, France, April 16-19, 2018. IEEE Computer Society, 1507\u20131518.","DOI":"10.1109\/ICDE.2018.00169"},{"key":"S147106842100034X_ref13","doi-asserted-by":"crossref","unstructured":"Do, T. M. , Loke, S. W. and Liu, F. 2011. Answer set programming for stream reasoning. In Canadian Conference on AI. LNCS, vol. 6657. Springer, 104\u2013109.","DOI":"10.1007\/978-3-642-21043-3_13"},{"key":"S147106842100034X_ref5","doi-asserted-by":"crossref","unstructured":"Beck, H. , Dao-Tran, M. and Eiter, T. 2018. LARS: A logic-based framework for analytic reasoning over streams. Artificial Intelligence 261, 16\u201370.","DOI":"10.1016\/j.artint.2018.04.003"},{"key":"S147106842100034X_ref15","doi-asserted-by":"crossref","unstructured":"Gebser, M. , Grote, T. , Kaminski, R. and Schaub, T. 2011. Reactive answer set programming. In LPNMR. LNCS, vol. 6645. Springer, 54\u201366.","DOI":"10.1007\/978-3-642-20895-9_7"},{"key":"S147106842100034X_ref26","doi-asserted-by":"crossref","unstructured":"Toshniwal, A. , Taneja, S. , Shukla, A. , Ramasamy, K. , Patel, J. M. , Kulkarni, S. , Jackson, J. , Gade, K. , Fu, M. , Donham, J. , Bhagat, N. , Mittal, S. and Ryaboy, D. V. 2014. Storm@twitter. In SIGMOD Conference. ACM, 147\u2013156.","DOI":"10.1145\/2588555.2595641"},{"key":"S147106842100034X_ref9","doi-asserted-by":"publisher","DOI":"10.3233\/IA-170104"},{"key":"S147106842100034X_ref2","doi-asserted-by":"crossref","unstructured":"Bazoobandi, H. R. , Beck, H. and Urbani, J. 2017. Expressive stream reasoning with laser. In International Semantic Web Conference (1). LNCS, vol. 10587. Springer, 87\u2013103.","DOI":"10.1007\/978-3-319-68288-4_6"},{"key":"S147106842100034X_ref17","doi-asserted-by":"crossref","unstructured":"Gebser, M. , Leone, N. , Maratea, M. , Perri, S. , Ricca, F. and Schaub, T. 2018. Evaluation techniques and systems for answer set programming: a survey. In IJCAI. ijcai.org, 5450\u20135456.","DOI":"10.24963\/ijcai.2018\/769"},{"key":"S147106842100034X_ref22","doi-asserted-by":"crossref","unstructured":"Mileo, A. , Abdelrahman, A. , Policarpio, S. and Hauswirth, M. 2013. Streamrule: A nonmonotonic stream reasoning system for the semantic web. In RR. LNCS, vol. 7994. Springer, 247\u2013252.","DOI":"10.1007\/978-3-642-39666-3_23"},{"key":"S147106842100034X_ref8","first-page":"294","article-title":"Asp-core-2 input language format","volume":"2","author":"Calimeri","year":"2020","journal-title":"TPLP 20"},{"key":"S147106842100034X_ref20","doi-asserted-by":"publisher","DOI":"10.1017\/S147106842000040X"},{"key":"S147106842100034X_ref7","doi-asserted-by":"publisher","DOI":"10.1145\/2043174.2043195"},{"key":"S147106842100034X_ref23","doi-asserted-by":"crossref","unstructured":"Pham, T. , Ali, M. I. and Mileo, A. 2019. C-ASP: continuous asp-based reasoning over RDF streams. In LPNMR. LNCS, vol. 11481. Springer, 45\u201350.","DOI":"10.1007\/978-3-030-20528-7_4"},{"key":"S147106842100034X_ref4","volume-title":"In IJCAI","author":"Beck","year":"2015"},{"key":"S147106842100034X_ref18","unstructured":"Hoeksema, J. and Kotoulas, S. 2011. High-performance distributed stream reasoning using s4. In Ordring Workshop at ISWC."},{"key":"S147106842100034X_ref24","doi-asserted-by":"crossref","unstructured":"Phuoc, D. L. , Dao-Tran, M. , Parreira, J. X. and Hauswirth, M. 2011. A native and adaptive approach for unified processing of linked streams and linked data. In International Semantic Web Conference (1). LNCS, vol. 7031. Springer, 370\u2013388.","DOI":"10.1007\/978-3-642-25073-6_24"},{"key":"S147106842100034X_ref10","doi-asserted-by":"publisher","DOI":"10.1017\/S1471068419000292"},{"key":"S147106842100034X_ref16","doi-asserted-by":"crossref","unstructured":"Gebser, M. , Kaminski, R. , Kaufmann, B. and Schaub, T. 2019. Multi-shot ASP solving with clingo. TPLP 19, 1, 27\u201382.","DOI":"10.1017\/S1471068418000054"},{"key":"S147106842100034X_ref25","doi-asserted-by":"crossref","unstructured":"Ren, X. , Cur\u00e9, O. , Naacke, H. and Xiao, G. 2018. Bigsr: real-time expressive RDF stream reasoning on modern big data platforms. In IEEE BigData. IEEE, 811\u2013820.","DOI":"10.1109\/BigData.2018.8621947"}],"container-title":["Theory and Practice of Logic Programming"],"original-title":[],"language":"en","link":[{"URL":"https:\/\/www.cambridge.org\/core\/services\/aop-cambridge-core\/content\/view\/S147106842100034X","content-type":"unspecified","content-version":"vor","intended-application":"similarity-checking"}],"deposited":{"date-parts":[[2021,11,18]],"date-time":"2021-11-18T09:18:53Z","timestamp":1637227133000},"score":1,"resource":{"primary":{"URL":"https:\/\/www.cambridge.org\/core\/product\/identifier\/S147106842100034X\/type\/journal_article"}},"subtitle":[],"short-title":[],"issued":{"date-parts":[[2021,9]]},"references-count":26,"journal-issue":{"issue":"5","published-print":{"date-parts":[[2021,9]]}},"alternative-id":["S147106842100034X"],"URL":"https:\/\/doi.org\/10.1017\/s147106842100034x","relation":{},"ISSN":["1471-0684","1475-3081"],"issn-type":[{"value":"1471-0684","type":"print"},{"value":"1475-3081","type":"electronic"}],"subject":[],"published":{"date-parts":[[2021,9]]},"assertion":[{"value":"\u00a9 The Author(s), 2021. Published by Cambridge University Press","name":"copyright","label":"Copyright","group":{"name":"copyright_and_licensing","label":"Copyright and Licensing"}}]}}