{"status":"ok","message-type":"work","message-version":"1.0.0","message":{"indexed":{"date-parts":[[2025,2,21]],"date-time":"2025-02-21T00:52:24Z","timestamp":1740099144673,"version":"3.37.3"},"publisher-location":"Cham","reference-count":25,"publisher":"Springer International Publishing","isbn-type":[{"type":"print","value":"9783030000622"},{"type":"electronic","value":"9783030000639"}],"license":[{"start":{"date-parts":[[2018,1,1]],"date-time":"2018-01-01T00:00:00Z","timestamp":1514764800000},"content-version":"unspecified","delay-in-days":0,"URL":"http:\/\/www.springer.com\/tdm"}],"content-domain":{"domain":["link.springer.com"],"crossmark-restriction":false},"short-container-title":[],"published-print":{"date-parts":[[2018]]},"DOI":"10.1007\/978-3-030-00063-9_38","type":"book-chapter","created":{"date-parts":[[2018,8,30]],"date-time":"2018-08-30T05:39:46Z","timestamp":1535607586000},"page":"413-422","update-policy":"https:\/\/doi.org\/10.1007\/springer_crossmark_policy","source":"Crossref","is-referenced-by-count":0,"title":["Consistency Maintenance in Distributed Analytical Stream Processing"],"prefix":"10.1007","author":[{"given":"Artem","family":"Trofimov","sequence":"first","affiliation":[]}],"member":"297","published-online":{"date-parts":[[2018,8,31]]},"reference":[{"key":"38_CR1","unstructured":"Apache Hadoop, October 2017. http:\/\/hadoop.apache.org\/"},{"key":"38_CR2","unstructured":"Trident, March 2018. http:\/\/storm.apache.org\/releases\/current\/Trident-tutorial.html"},{"issue":"11","key":"38_CR3","doi-asserted-by":"publisher","first-page":"1033","DOI":"10.14778\/2536222.2536229","volume":"6","author":"T Akidau","year":"2013","unstructured":"Akidau, T., et al.: Millwheel: fault-tolerant stream processing at internet scale. Proc. VLDB 6(11), 1033\u20131044 (2013)","journal-title":"Proc. VLDB"},{"key":"38_CR4","unstructured":"Apache Storm, Octoner 2017. http:\/\/storm.apache.org\/"},{"key":"38_CR5","doi-asserted-by":"publisher","unstructured":"Baylor, D., et al.: Tfx: a tensorflow-based production-scale machine learning platform. In: Proceedings of the 23rd ACM SIGKDD International Conference on Knowledge Discovery and Data Mining, KDD 2017, pp. 1387\u20131395. ACM, New York (2017). https:\/\/doi.org\/10.1145\/3097983.3098021","DOI":"10.1145\/3097983.3098021"},{"issue":"12","key":"38_CR6","doi-asserted-by":"publisher","first-page":"1718","DOI":"10.14778\/3137765.3137777","volume":"10","author":"P Carbone","year":"2017","unstructured":"Carbone, P., Ewen, S., F\u00f3ra, G., Haridi, S., Richter, S., Tzoumas, K.: State management in Apache Flink$${\\textregistered }$$: consistent stateful distributed stream processing. Proc. VLDB 10(12), 1718\u20131729 (2017)","journal-title":"Proc. VLDB"},{"issue":"4","key":"38_CR7","first-page":"28","volume":"36","author":"P Carbone","year":"2015","unstructured":"Carbone, P., Katsifodimos, A., Ewen, S., Markl, V., Haridi, S., Tzoumas, K.: Apache Flink: stream and batch processing in a single engine. Bull. IEEE Comput. Soc. Tech. Comm. Data Eng. 36(4), 28\u201338 (2015)","journal-title":"Bull. IEEE Comput. Soc. Tech. Comm. Data Eng."},{"key":"38_CR8","doi-asserted-by":"publisher","unstructured":"Chintapalli, S., et al.: Benchmarking streaming computation engines: storm, flink and spark streaming. In: 2016 IEEE International Parallel and Distributed Processing Symposium Workshops (IPDPSW), pp. 1789\u20131792, May 2016. https:\/\/doi.org\/10.1109\/IPDPSW.2016.138","DOI":"10.1109\/IPDPSW.2016.138"},{"issue":"1","key":"38_CR9","doi-asserted-by":"publisher","first-page":"107","DOI":"10.1145\/1327452.1327492","volume":"51","author":"J Dean","year":"2008","unstructured":"Dean, J., Ghemawat, S.: Mapreduce: simplified data processing on large clusters. Commun. ACM 51(1), 107\u2013113 (2008). https:\/\/doi.org\/10.1145\/1327452.1327492","journal-title":"Commun. ACM"},{"issue":"3","key":"38_CR10","doi-asserted-by":"publisher","first-page":"355","DOI":"10.1007\/s00778-013-0319-9","volume":"23","author":"C Doulkeridis","year":"2014","unstructured":"Doulkeridis, C., Norvaag, K.: A survey of large-scale analytical query processing in mapreduce. VLDB J. 23(3), 355\u2013380 (2014)","journal-title":"VLDB J."},{"key":"38_CR11","doi-asserted-by":"publisher","unstructured":"Fischer, P.M., Esmaili, K.S., Miller, R.J.: Stream schema: providing and exploiting static metadata for data stream processing. In: Proceedings of the 13th International Conference on Extending Database Technology, EDBT 2010, pp. 207\u2013218. ACM, New York (2010). https:\/\/doi.org\/10.1145\/1739041.1739068","DOI":"10.1145\/1739041.1739068"},{"issue":"2","key":"38_CR12","doi-asserted-by":"publisher","first-page":"186","DOI":"10.1145\/319983.319985","volume":"8","author":"H Garcia-Molina","year":"1983","unstructured":"Garcia-Molina, H.: Using semantic knowledge for transaction processing in a distributed database. ACM Trans. Database Syst. 8(2), 186\u2013213 (1983). https:\/\/doi.org\/10.1145\/319983.319985","journal-title":"ACM Trans. Database Syst."},{"key":"38_CR13","doi-asserted-by":"publisher","unstructured":"Guo, J., Lam, I.H., Chan, C., Xiao, G.: Collaboratively maintaining semantic consistency of heterogeneous concepts towards a common concept set. In: Proceedings of the 2nd ACM SIGCHI Symposium on Engineering Interactive Computing Systems, EICS 2010, pp. 213\u2013218. ACM, New York (2010). https:\/\/doi.org\/10.1145\/1822018.1822052","DOI":"10.1145\/1822018.1822052"},{"key":"38_CR14","unstructured":"Hambling, B., Van Goethem, P.: User acceptance testing: a step-by-step guide. BCS Learning & Development (2013)"},{"issue":"13","key":"38_CR15","doi-asserted-by":"publisher","first-page":"1341","DOI":"10.14778\/3007263.3007272","volume":"9","author":"G Jacques-Silva","year":"2016","unstructured":"Jacques-Silva, G., et al.: Consistent regions: guaranteed tuple processing in IBM streams. Proc. VLDB Endow. 9(13), 1341\u20131352 (2016)","journal-title":"Proc. VLDB Endow."},{"key":"38_CR16","doi-asserted-by":"publisher","unstructured":"Kulkarni, S., et al.: Twitter heron: stream processing at scale. In: Proceedings of the 2015 ACM SIGMOD International Conference on Management of Data, SIGMOD 2015, pp. 239\u2013250. ACM, New York (2015). https:\/\/doi.org\/10.1145\/2723372.2742788","DOI":"10.1145\/2723372.2742788"},{"key":"38_CR17","unstructured":"Kuralenok, I.E., Marshalkin, N., Trofimov, A., Novikov, B.: An optimistic approach to handle out-of-order events within analytical stream processing. Accepted at SEIM (2018). http:\/\/seim-conf.org\/en\/about\/accepted-papers\/"},{"key":"38_CR18","doi-asserted-by":"publisher","unstructured":"Kuralenok, I.E., Trofimov, A., Marshalkin, N., Novikov, B.: Flamestream: model and runtime for distributed stream processing. In: Proceedings of the 5th ACM SIGMOD Workshop on Algorithms and Systems for MapReduce and Beyond, BeyondMR 2018, pp. 8:1\u20138:2. ACM, New York (2018). https:\/\/doi.org\/10.1145\/3206333.3209273","DOI":"10.1145\/3206333.3209273"},{"issue":"1","key":"38_CR19","doi-asserted-by":"publisher","first-page":"274","DOI":"10.14778\/1453856.1453890","volume":"1","author":"J Li","year":"2008","unstructured":"Li, J., Tufte, K., Shkapenyuk, V., Papadimos, V., Johnson, T., Maier, D.: Out-of-order processing: a new architecture for high-performance stream systems. Proc. VLDB Endow. 1(1), 274\u2013288 (2008)","journal-title":"Proc. VLDB Endow."},{"key":"38_CR20","doi-asserted-by":"publisher","unstructured":"Mihaila, G.A., Stanoi, I., Lang, C.A.: Anomaly-free incremental output in stream processing. In: Proceedings of the 17th ACM Conference on Information and Knowledge Management, CIKM 2008, pp. 359\u2013368. ACM, New York (2008). https:\/\/doi.org\/10.1145\/1458082.1458132","DOI":"10.1145\/1458082.1458132"},{"issue":"12","key":"38_CR21","doi-asserted-by":"publisher","first-page":"1634","DOI":"10.14778\/3137765.3137770","volume":"10","author":"SA Noghabi","year":"2017","unstructured":"Noghabi, S.A., et al.: Samza: stateful scalable stream processing at Linkedin. Proc. VLDB Endow. 10(12), 1634\u20131645 (2017)","journal-title":"Proc. VLDB Endow."},{"key":"38_CR22","doi-asserted-by":"publisher","unstructured":"Rodr\u00edguez, M.A., Bertossi, L., Caniup\u00e1n, M.: An inconsistency tolerant approach to querying spatial databases. In: Proceedings of the 16th ACM SIGSPATIAL International Conference on Advances in Geographic Information Systems, GIS 2008, pp. 36:1\u201336:10. ACM, New York (2008). https:\/\/doi.org\/10.1145\/1463434.1463480","DOI":"10.1145\/1463434.1463480"},{"issue":"3","key":"38_CR23","doi-asserted-by":"publisher","first-page":"555","DOI":"10.1109\/TKDE.2003.1198390","volume":"15","author":"PA Tucker","year":"2003","unstructured":"Tucker, P.A., Maier, D., Sheard, T., Fegaras, L.: Exploiting punctuation semantics in continuous data streams. IEEE Trans. Knowl. Data Eng. 15(3), 555\u2013568 (2003). https:\/\/doi.org\/10.1109\/TKDE.2003.1198390","journal-title":"IEEE Trans. Knowl. Data Eng."},{"key":"38_CR24","doi-asserted-by":"crossref","unstructured":"Zaharia, M., Das, T., Li, H., Shenker, S., Stoica, I.: Discretized streams: an efficient and fault-tolerant model for stream processing on large clusters. In: Proceedings of the 4th USENIX Conference on Hot Topics in Cloud Ccomputing, HotCloud 2012, p. 10. USENIX Association, Berkeley (2012)","DOI":"10.21236\/ADA575859"},{"issue":"1\u20132","key":"38_CR25","doi-asserted-by":"publisher","first-page":"1394","DOI":"10.14778\/1920841.1921012","volume":"3","author":"Q Zou","year":"2010","unstructured":"Zou, Q., et al.: From a stream of relational queries to distributed stream processing. Proc. VLDB Endow. 3(1\u20132), 1394\u20131405 (2010)","journal-title":"Proc. VLDB Endow."}],"container-title":["Communications in Computer and Information Science","New Trends in Databases and Information Systems"],"original-title":[],"link":[{"URL":"http:\/\/link.springer.com\/content\/pdf\/10.1007\/978-3-030-00063-9_38","content-type":"unspecified","content-version":"vor","intended-application":"similarity-checking"}],"deposited":{"date-parts":[[2019,10,23]],"date-time":"2019-10-23T02:59:33Z","timestamp":1571799573000},"score":1,"resource":{"primary":{"URL":"http:\/\/link.springer.com\/10.1007\/978-3-030-00063-9_38"}},"subtitle":[],"short-title":[],"issued":{"date-parts":[[2018]]},"ISBN":["9783030000622","9783030000639"],"references-count":25,"URL":"https:\/\/doi.org\/10.1007\/978-3-030-00063-9_38","relation":{},"ISSN":["1865-0929","1865-0937"],"issn-type":[{"type":"print","value":"1865-0929"},{"type":"electronic","value":"1865-0937"}],"subject":[],"published":{"date-parts":[[2018]]}}}