{"status":"ok","message-type":"work","message-version":"1.0.0","message":{"indexed":{"date-parts":[[2025,10,17]],"date-time":"2025-10-17T13:54:25Z","timestamp":1760709265803},"publisher-location":"Cham","reference-count":90,"publisher":"Springer International Publishing","isbn-type":[{"type":"print","value":"9783319493398"},{"type":"electronic","value":"9783319493404"}],"license":[{"start":{"date-parts":[[2017,1,1]],"date-time":"2017-01-01T00:00:00Z","timestamp":1483228800000},"content-version":"unspecified","delay-in-days":0,"URL":"http:\/\/www.springer.com\/tdm"}],"content-domain":{"domain":[],"crossmark-restriction":false},"short-container-title":[],"published-print":{"date-parts":[[2017]]},"DOI":"10.1007\/978-3-319-49340-4_7","type":"book-chapter","created":{"date-parts":[[2017,2,25]],"date-time":"2017-02-25T08:23:30Z","timestamp":1488011010000},"page":"219-260","source":"Crossref","is-referenced-by-count":9,"title":["Large-Scale Data Stream Processing Systems"],"prefix":"10.1007","author":[{"given":"Paris","family":"Carbone","sequence":"first","affiliation":[],"role":[{"role":"author","vocabulary":"crossref"}]},{"given":"G\u00e1bor E.","family":"G\u00e9vay","sequence":"additional","affiliation":[],"role":[{"role":"author","vocabulary":"crossref"}]},{"given":"G\u00e1bor","family":"Hermann","sequence":"additional","affiliation":[],"role":[{"role":"author","vocabulary":"crossref"}]},{"given":"Asterios","family":"Katsifodimos","sequence":"additional","affiliation":[],"role":[{"role":"author","vocabulary":"crossref"}]},{"given":"Juan","family":"Soto","sequence":"additional","affiliation":[],"role":[{"role":"author","vocabulary":"crossref"}]},{"given":"Volker","family":"Markl","sequence":"additional","affiliation":[],"role":[{"role":"author","vocabulary":"crossref"}]},{"given":"Seif","family":"Haridi","sequence":"additional","affiliation":[],"role":[{"role":"author","vocabulary":"crossref"}]}],"member":"297","published-online":{"date-parts":[[2017,2,26]]},"reference":[{"key":"7_CR1","unstructured":"Apache Hadoop project, https:\/\/hadoop.apache.org\/"},{"key":"7_CR2","unstructured":"Apache Kafka project, http:\/\/kafka.apache.org\/"},{"key":"7_CR3","unstructured":"Apache Samza project, http:\/\/samza.apache.org\/"},{"key":"7_CR4","unstructured":"Apache Spark project, http:\/\/spark.apache.org\/"},{"key":"7_CR5","unstructured":"Apache Storm project, http:\/\/storm.apache.org\/"},{"key":"7_CR6","doi-asserted-by":"crossref","unstructured":"D.J. Abadi, D. Carney, U. \u00c7etintemel, M. Cherniack, C. Convey, S. Lee, M. Stonebraker, N. Tatbul, S. Zdonik, Aurora: a new model and architecture for data stream management, in VLDBJ (2003)","DOI":"10.1007\/s00778-003-0095-z"},{"key":"7_CR7","unstructured":"D.J. Abadi, Y. Ahmad, M. Balazinska, U. Cetintemel, M. Cherniack, J.H. Hwang, W. Lindner, A. Maskey, A. Rasin, E. Ryvkina et\u00a0al., The design of the Borealis stream processing engine, in CIDR (2005)"},{"key":"7_CR8","doi-asserted-by":"crossref","unstructured":"K.J. Ahn, S. Guha, A. McGregor, Graph sketches: sparsification, spanners, and subgraphs, in Proceedings of the 31st symposium on Principles of Database Systems. ACM (2012), pp. 5\u201314","DOI":"10.1145\/2213556.2213560"},{"key":"7_CR9","doi-asserted-by":"crossref","unstructured":"T. Akidau, A. Balikov, K. Bekiroglu, S. Chernyak, J. Haberman, R. Lax, S. McVeety, D. Mills, P. Nordstrom, S. Whittle, MillWheel: Fault-tolerant stream processing at internet scale, in VLDB (2013)","DOI":"10.14778\/2536222.2536229"},{"key":"7_CR10","doi-asserted-by":"crossref","unstructured":"T. Akidau, R. Bradshaw, C. Chambers, S. Chernyak, R.J. Fern\u00e1ndez-Moctezuma, R. Lax, S. McVeety, D. Mills, F. Perry, E. Schmidt et\u00a0al, The dataflow model: a practical approach to balancing correctness, latency, and cost in massive-scale, unbounded, out-of-order data processing, in VLDB (2015)","DOI":"10.14778\/2824032.2824076"},{"issue":"6","key":"7_CR11","doi-asserted-by":"crossref","first-page":"939","DOI":"10.1007\/s00778-014-0357-y","volume":"23","author":"A Alexandrov","year":"2014","unstructured":"A. Alexandrov, R. Bergmann, S. Ewen, J.C. Freytag, F. Hueske, A. Heise, O. Kao, M. Leich, U. Leser, V. Markl et al., The Stratosphere platform for big data analytics. VLDB J. - Int. J. Very Large Data Bases 23(6), 939\u2013964 (2014)","journal-title":"VLDB J. - Int. J. Very Large Data Bases"},{"key":"7_CR12","unstructured":"A. Alexandrov, A. Kunft, A. Katsifodimos, F. Sch\u00fcler, L. Thamsen, O. Kao, T. Herb, V. Markl, Implicit parallelism through deep language embedding, in ACM SIGMOD (2015), pp. 47\u201361"},{"key":"7_CR13","doi-asserted-by":"crossref","unstructured":"A. Arasu, B. Babcock, S. Babu, J. Cieslewicz, M. Datar, K. Ito, R. Motwani, U. Srivastava, J. Widom, Stream: The stanford data stream management system, Book chapter (2004)","DOI":"10.1145\/872757.872854"},{"key":"7_CR14","unstructured":"A. Arasu, M. Cherniack, E. Galvez, D. Maier, A.S. Maskey, E. Ryvkina, M. Stonebraker, R. Tibbetts, Linear road: a stream data management benchmark. in Proceedings of the Thirtieth International Conference on Very Large Data Bases, VLDB Endowment, vol. 30 (2004), pp. 480\u2013491"},{"key":"7_CR15","doi-asserted-by":"crossref","unstructured":"A. Arasu, S. Babu, J. Widom, The CQL continuous query language: semantic foundations and query execution, in VLDBJ (2006)","DOI":"10.1007\/s00778-004-0147-z"},{"issue":"1","key":"7_CR16","doi-asserted-by":"crossref","first-page":"3","DOI":"10.1145\/1331904.1331907","volume":"33","author":"M Balazinska","year":"2008","unstructured":"M. Balazinska, H. Balakrishnan, S.R. Madden, M. Stonebraker, Fault-tolerance in the Borealis distributed stream processing system. ACM Trans. Database Syst. (TODS) 33(1), 3 (2008)","journal-title":"ACM Trans. Database Syst. (TODS)"},{"key":"7_CR17","doi-asserted-by":"crossref","unstructured":"M. Balazinska, J.H. Hwang, M.A. Shah, Fault-tolerance and high availability in data stream management systems., in Encyclopedia of Database Systems (Springer, 2009), pp. 1109\u20131115","DOI":"10.1007\/978-0-387-39940-9_160"},{"key":"7_CR18","doi-asserted-by":"crossref","unstructured":"L. Becchetti, P. Boldi, C. Castillo, A. Gionis, Efficient semi-streaming algorithms for local triangle counting in massive graphs, in Proceedings of the 14th ACM SIGKDD International Conference on Knowledge Discovery and Data Mining (ACM, 2008), pp. 16\u201324","DOI":"10.1145\/1401890.1401898"},{"key":"7_CR19","unstructured":"Benchmarking streaming computation engines at Yahoo! https:\/\/yahooeng.tumblr.com\/post\/135321837876\/benchmarking-streaming-computation-engines-at"},{"key":"7_CR20","unstructured":"T. Bernhardt, A. Vasseur, Esper: Event Stream Processing and Correlation. ON-Java (O\u2019Reilly, Springfield, 2007)"},{"key":"7_CR21","doi-asserted-by":"crossref","unstructured":"A. Bifet, R. Gavald\u00e0, Adaptive learning from evolving data streams, in Advances in Intelligent Data Analysis VIII (Springer, Berlin, 2009), pp. 249\u2013260","DOI":"10.1007\/978-3-642-03915-7_22"},{"key":"7_CR22","first-page":"1601","volume":"11","author":"A Bifet","year":"2010","unstructured":"A. Bifet, G. Holmes, R. Kirkby, B. Pfahringer, Moa: Massive online analysis. J. Mach. Learn. Res. 11, 1601\u20131604 (2010)","journal-title":"J. Mach. Learn. Res."},{"key":"7_CR23","doi-asserted-by":"crossref","unstructured":"I. Botan, R. Derakhshan, N. Dindar, L. Haas, R.J. Miller, N. Tatbul, Secret: A model for analysis of the execution semantics of stream processing systems, in VLDB (2010)","DOI":"10.14778\/1920841.1920874"},{"key":"7_CR24","doi-asserted-by":"crossref","unstructured":"L. Brenna, A. Demers, J. Gehrke, M. Hong, J. Ossher, B. Panda, M. Riedewald, M. Thatte, W. White, Cayuga: a high-performance event processing engine, in Proceedings of the 2007 ACM SIGMOD International Conference on Management of Data (ACM, 2007), pp. 1100\u20131102","DOI":"10.1145\/1247480.1247620"},{"key":"7_CR25","doi-asserted-by":"crossref","unstructured":"P. Carbone, K. Vandikas, F. Zaloshnja, Towards highly available complex event processing deployments in the cloud, in Seventh International Conference on Next Generation Mobile Apps, Services and Technologies (NGMAST) (IEEE, 2013), pp. 153\u2013158","DOI":"10.1109\/NGMAST.2013.35"},{"key":"7_CR26","unstructured":"P. Carbone, S. Ewen, S. Haridi, A. Katsifodimos, V. Markl, K. Tzoumas, Apache Flink: Stream and batch processing in a single engine. IEEE Data Engineering Bulletin (2015)"},{"key":"7_CR27","unstructured":"P. Carbone, G. F\u00f3ra, S. Ewen, S. Haridi, K. Tzoumas, Lightweight asynchronous snapshots for distributed dataflows (2015). arXiv preprint arXiv:1506.08603"},{"key":"7_CR28","doi-asserted-by":"crossref","unstructured":"P. Carbone, J. Traub, A. Katsifodimos, S. Haridi, V. Markl, Cutty: Aggregate sharing for user-defined windows, in Proceedings of the 25th ACM International on Conference on Information and Knowledge Management (ACM, 2016)","DOI":"10.1145\/2983323.2983807"},{"issue":"3","key":"7_CR29","doi-asserted-by":"crossref","first-page":"332","DOI":"10.1145\/380749.380767","volume":"19","author":"A Carzaniga","year":"2001","unstructured":"A. Carzaniga, D.S. Rosenblum, A.L. Wolf, Design and evaluation of a wide-area event notification service. ACM Trans. Comput. Syst. (TOCS) 19(3), 332\u2013383 (2001)","journal-title":"ACM Trans. Comput. Syst. (TOCS)"},{"key":"7_CR30","doi-asserted-by":"crossref","unstructured":"R. Castro\u00a0Fernandez, M. Migliavacca, E. Kalyvianaki, P. Pietzuch, Integrating scale out and fault tolerance in stream processing using operator state management, in Proceedings of the 2013 ACM SIGMOD international conference on Management of data (ACM, 2013), pp. 725\u2013736","DOI":"10.1145\/2463676.2465282"},{"issue":"13","key":"7_CR31","doi-asserted-by":"crossref","first-page":"1633","DOI":"10.14778\/2733004.2733048","volume":"7","author":"U Cetintemel","year":"2014","unstructured":"U. Cetintemel, J. Du, T. Kraska, S. Madden, D. Maier, J. Meehan, A. Pavlo, M. Stonebraker, E. Sutherland, N. Tatbul et al., S-store: A streaming newSQL system for big velocity applications. Proc. VLDB Endow. 7(13), 1633\u20131636 (2014)","journal-title":"Proc. VLDB Endow."},{"key":"7_CR32","doi-asserted-by":"crossref","unstructured":"C. Chambers, A. Raniwala, F. Perry, S. Adams, R.R. Henry, R. Bradshaw, N. Weizenbaum, FlumeJava: easy, efficient data-parallel pipelines, in ACM Sigplan Notices, vol.\u00a045 (ACM, 2010), pp. 363\u2013375","DOI":"10.1145\/1806596.1806638"},{"issue":"4","key":"7_CR33","doi-asserted-by":"crossref","first-page":"401","DOI":"10.14778\/2735496.2735503","volume":"8","author":"B Chandramouli","year":"2014","unstructured":"B. Chandramouli, J. Goldstein, M. Barnett, R. DeLine, D. Fisher, J.C. Platt, J.F. Terwilliger, J. Wernsing, Trill: A high-performance incremental query processor for diverse analytics. Proc. VLDB Endow. 8(4), 401\u2013412 (2014)","journal-title":"Proc. VLDB Endow."},{"key":"7_CR34","doi-asserted-by":"crossref","unstructured":"S. Chandrasekaran, O. Cooper, A. Deshpande, M.J. Franklin, J.M. Hellerstein, W. Hong, S. Krishnamurthy, S.R. Madden, F. Reiss, M.A. Shah, TelegraphCQ: continuous dataflow processing, in Proceedings of the 2003 ACM SIGMOD International Conference on Management of Data (ACM, 2003), pp. 668\u2013668","DOI":"10.1145\/872757.872857"},{"issue":"1","key":"7_CR35","doi-asserted-by":"crossref","first-page":"63","DOI":"10.1145\/214451.214456","volume":"3","author":"KM Chandy","year":"1985","unstructured":"K.M. Chandy, L. Lamport, Distributed snapshots: determining global states of distributed systems. ACM Trans. Comput. Syst. (TOCS) 3(1), 63\u201375 (1985)","journal-title":"ACM Trans. Comput. Syst. (TOCS)"},{"issue":"2","key":"7_CR36","doi-asserted-by":"crossref","first-page":"4","DOI":"10.1145\/1365815.1365816","volume":"26","author":"F Chang","year":"2008","unstructured":"F. Chang, J. Dean, S. Ghemawat, W.C. Hsieh, D.A. Wallach, M. Burrows, T. Chandra, A. Fikes, R.E. Gruber, Bigtable: A distributed storage system for structured data. ACM Trans. Comput. Syst. (TOCS) 26(2), 4 (2008)","journal-title":"ACM Trans. Comput. Syst. (TOCS)"},{"key":"7_CR37","doi-asserted-by":"crossref","unstructured":"J. Chen, D.J. DeWitt, F. Tian, Y. Wang, Niagaracq: A scalable continuous query system for internet databases, in SIGMOD Record (ACM, 2000)","DOI":"10.1145\/342009.335432"},{"key":"7_CR38","unstructured":"M. Cherniack, H. Balakrishnan, M. Balazinska, D. Carney, U. Cetintemel, Y. Xing, S.B. Zdonik, Scalable distributed stream processing. CIDR. 3, 257\u2013268 (2003)"},{"key":"7_CR39","unstructured":"T. Condie, N. Conway, P. Alvaro, J.M. Hellerstein, K. Elmeleegy, R. Sears, Mapreduce online. NSDI. 10, 20 (2010)"},{"issue":"3","key":"7_CR40","doi-asserted-by":"crossref","first-page":"15","DOI":"10.1145\/2187671.2187677","volume":"44","author":"G Cugola","year":"2012","unstructured":"G. Cugola, A. Margara, Processing flows of information: From data stream to complex event processing. ACM Comput. Surv. (CSUR) 44(3), 15 (2012)","journal-title":"ACM Comput. Surv. (CSUR)"},{"issue":"1","key":"7_CR41","doi-asserted-by":"crossref","first-page":"51","DOI":"10.1145\/44203.44208","volume":"17","author":"U Dayal","year":"1988","unstructured":"U. Dayal, B. Blaustein, A. Buchmann, U. Chakravarthy, M. Hsu, R. Ledin, D. McCarthy, A. Rosenthal, S. Sarin, M.J. Carey et al., The HiPAC project: Combining active databases and timing constraints. ACM Sigmod Rec. 17(1), 51\u201370 (1988)","journal-title":"ACM Sigmod Rec."},{"key":"7_CR42","unstructured":"G. De Francisci Morales, A. Bifet, Samoa: Scalable advanced massive online analysis. J. Mach. Learn. Res. 16(1), 149\u2013153 (2015)"},{"issue":"1","key":"7_CR43","doi-asserted-by":"crossref","first-page":"107","DOI":"10.1145\/1327452.1327492","volume":"51","author":"J Dean","year":"2008","unstructured":"J. Dean, S. Ghemawat, Mapreduce: simplified data processing on large clusters. Commun. ACM 51(1), 107\u2013113 (2008)","journal-title":"Commun. ACM"},{"issue":"4","key":"7_CR44","doi-asserted-by":"crossref","first-page":"421","DOI":"10.1007\/s00778-012-0297-3","volume":"22","author":"N Dindar","year":"2013","unstructured":"N. Dindar, N. Tatbul, R.J. Miller, L.M. Haas, I. Botan, Modeling the execution semantics of stream processing engines with secret. VLDB J. 22(4), 421\u2013446 (2013)","journal-title":"VLDB J."},{"key":"7_CR45","unstructured":"D. Elin, T. Risch, Amos II java interfaces. Uppsala University report (2000)"},{"issue":"2","key":"7_CR46","doi-asserted-by":"crossref","first-page":"207","DOI":"10.1016\/j.tcs.2005.09.013","volume":"348","author":"J Feigenbaum","year":"2005","unstructured":"J. Feigenbaum, S. Kannan, A. McGregor, S. Suri, J. Zhang, On graph problems in a semi-streaming model. Theor. Comput. Sci. 348(2), 207\u2013216 (2005)","journal-title":"Theor. Comput. Sci."},{"key":"7_CR47","unstructured":"R.C. Fernandez, M. Migliavacca, E. Kalyvianaki, P. Pietzuch, Making state explicit for imperative big data processing, in Proceedings of the 2014 USENIX Annual Technical Conference (USENIX ATC 14) (2014), pp. 49\u201360"},{"issue":"1\u20134","key":"7_CR48","first-page":"23","volume":"15","author":"S Gatziu","year":"1992","unstructured":"S. Gatziu, K.R. Dittrich, Samos: An active object-oriented database system. IEEE Data Eng. Bull. 15(1\u20134), 23\u201326 (1992)","journal-title":"IEEE Data Eng. Bull."},{"issue":"4","key":"7_CR49","doi-asserted-by":"crossref","first-page":"517","DOI":"10.1007\/s00778-013-0335-9","volume":"23","author":"B Gedik","year":"2014","unstructured":"B. Gedik, Partitioning functions for stateful data parallelism in stream processing. VLDB J. 23(4), 517\u2013539 (2014)","journal-title":"VLDB J."},{"key":"7_CR50","unstructured":"Google Cloud Dataflow, https:\/\/cloud.google.com\/dataflow\/"},{"key":"7_CR51","doi-asserted-by":"crossref","unstructured":"W. Han, Y. Miao, K. Li, M. Wu, F. Yang, L. Zhou, V. Prabhakaran, W. Chen, E. Chen, Chronos: a graph engine for temporal graph analysis, in Proceedings of the Ninth European Conference on Computer Systems (ACM, 2014), p. 1","DOI":"10.1145\/2592798.2592799"},{"key":"7_CR52","doi-asserted-by":"crossref","unstructured":"B. He, M. Yang, Z. Guo, R. Chen, B. Su, W. Lin, L. Zhou, Comet: batched stream processing for data intensive distributed computing, in Proceedings of the 1st ACM Symposium on Cloud Computing (ACM, 2010), pp. 63\u201374","DOI":"10.1145\/1807128.1807139"},{"key":"7_CR53","unstructured":"M. Hirzel, H. Andrade, B. Gedik, V. Kumar, G. Losa, M. Nasgaard, R. Soule, K. Wu, SPL stream processing language specification. NewYork: IBMResearchDivisionTJ. WatsonResearchCenter, IBM ResearchReport: RC24897 (W0911\u2013044) (2009)"},{"key":"7_CR54","doi-asserted-by":"crossref","unstructured":"M. Hirzel, H. Andrade, B. Gedik, G. Jacques-Silva, R. Khandekar, V. Kumar, M. Mendell, H. Nasgaard, S. Schneider, R. Soul\u00e9 et al., IBM streams processing language: analyzing big data in motion. IBM J. Res. Develop. 57(3\/4), 7\u20131 (2013)","DOI":"10.1147\/JRD.2013.2243535"},{"issue":"4","key":"7_CR55","doi-asserted-by":"crossref","first-page":"46","DOI":"10.1145\/2528412","volume":"46","author":"M Hirzel","year":"2014","unstructured":"M. Hirzel, R. Soul\u00e9, S. Schneider, B. Gedik, R. Grimm, A catalog of stream processing optimizations. ACM Comput. Surv. (CSUR) 46(4), 46 (2014)","journal-title":"ACM Comput. Surv. (CSUR)"},{"key":"7_CR56","unstructured":"Introduction to Kafka Streams, http:\/\/www.confluent.io\/blog\/introducing-kafka-streams-stream-processing-made-simple"},{"key":"7_CR57","unstructured":"A. Iyer, L.E. Li, I. Stoica, CellIQ: real-time cellular network analytics at scale, in 12th USENIX Symposium on Networked Systems Design and Implementation (NSDI 15) (2015), pp. 309\u2013322"},{"issue":"2","key":"7_CR58","doi-asserted-by":"crossref","first-page":"1496","DOI":"10.14778\/1454159.1454211","volume":"1","author":"R Kallman","year":"2008","unstructured":"R. Kallman, H. Kimura, J. Natkins, A. Pavlo, A. Rasin, S. Zdonik, E.P. Jones, S. Madden, M. Stonebraker, Y. Zhang et al., H-store: a high-performance, distributed main memory transaction processing system. Proc. VLDB Endow. 1(2), 1496\u20131499 (2008)","journal-title":"Proc. VLDB Endow."},{"issue":"4","key":"7_CR59","doi-asserted-by":"crossref","first-page":"217","DOI":"10.14778\/2732240.2732241","volume":"7","author":"K Karanasos","year":"2013","unstructured":"K. Karanasos, A. Katsifodimos, I. Manolescu, Delta: Scalable data dissemination under capacity constraints. Proc. VLDB Endow. 7(4), 217\u2013228 (2013)","journal-title":"Proc. VLDB Endow."},{"key":"7_CR60","unstructured":"J. Kreps, N. Narkhede, J. Rao et\u00a0al, Kafka: A distributed messaging system for log processing. NetDB (2011)"},{"key":"7_CR61","doi-asserted-by":"crossref","unstructured":"S. Kulkarni, N. Bhagat, M. Fu, V. Kedigehalli, C. Kellogg, S. Mittal, J.M. Patel, K. Ramasamy, S. Taneja, Twitter Heron: Stream processing at scale, in ACM SIGMOD (2015)","DOI":"10.1145\/2723372.2742788"},{"key":"7_CR62","unstructured":"A. Kyrola, G. Blelloch, C. Guestrin, Graphchi: Large-scale graph computation on just a pc, in Presented as part of the 10th USENIX Symposium on Operating Systems Design and Implementation (OSDI 12) (2012), pp. 31\u201346"},{"issue":"2","key":"7_CR63","doi-asserted-by":"crossref","first-page":"35","DOI":"10.1145\/1773912.1773922","volume":"44","author":"A Lakshman","year":"2010","unstructured":"A. Lakshman, P. Malik, Cassandra: a decentralized structured storage system. ACM SIGOPS Oper. Syst. Rev. 44(2), 35\u201340 (2010)","journal-title":"ACM SIGOPS Oper. Syst. Rev."},{"key":"7_CR64","doi-asserted-by":"crossref","unstructured":"J. Li, D. Maier, K. Tufte, V. Papadimos, P.A. Tucker, Semantics and evaluation techniques for window aggregates in data streams, in ACM SIGMOD (2005)","DOI":"10.1145\/1066157.1066193"},{"issue":"4","key":"7_CR65","doi-asserted-by":"crossref","first-page":"610","DOI":"10.1109\/69.790816","volume":"11","author":"L Liu","year":"1999","unstructured":"L. Liu, C. Pu, W. Tang, Continual queries for internet scale event-driven information delivery. IEEE Trans. Knowl. Data Eng. 11(4), 610\u2013628 (1999)","journal-title":"IEEE Trans. Knowl. Data Eng."},{"key":"7_CR66","unstructured":"Y. Liu, B. Plale et al., Survey of publish subscribe event systems. Computer Science Dept, Indian University 16 (2003)"},{"key":"7_CR67","doi-asserted-by":"crossref","unstructured":"D. Logothetis, C. Olston, B. Reed, K.C. Webb, K. Yocum, Stateful bulk processing for incremental analytics, in Proceedings of the 1st ACM Symposium on Cloud Computing (ACM, 2010), pp. 51\u201362","DOI":"10.1145\/1807128.1807138"},{"key":"7_CR68","unstructured":"D. Luckham, The power of events, vol. 204 (Addison-Wesley Reading, Boston, 2002)"},{"key":"7_CR69","doi-asserted-by":"crossref","unstructured":"G. Malewicz, M.H. Austern, A.J. Bik, J.C. Dehnert, I. Horn, N. Leiser, G. Czajkowski, Pregel: a system for large-scale graph processing, in Proceedings of the 2010 ACM SIGMOD International Conference on Management of Data (ACM, 2010), pp. 135\u2013146","DOI":"10.1145\/1807167.1807184"},{"key":"7_CR70","unstructured":"N. Marz, J. Warren, Big Data: Principles and Best Practices of Scalable Realtime Data Systems (Manning Publications Co., Greenwich, 2015)"},{"key":"7_CR71","unstructured":"D. Mishra, SNOOP: an event specification language for active database systems. Ph.D. thesis, University of Florida (1991)"},{"key":"7_CR72","unstructured":"S.S. Muchnick, Advanced Compiler Design Implementation (Morgan Kaufmann, Burlington, 1997)"},{"key":"7_CR73","doi-asserted-by":"crossref","unstructured":"D.G. Murray, F. McSherry, R. Isaacs, M. Isard, P. Barham, M. Abadi, Naiad: a timely dataflow system, in ACM SOSP (2013)","DOI":"10.1145\/2517349.2522738"},{"key":"7_CR74","doi-asserted-by":"crossref","unstructured":"L. Neumeyer, B. Robbins, A. Nair, A. Kesari, S4: Distributed stream computing platform, in Proceedings of the 2010 IEEE International Conference on Data Mining Workshops (IEEE, 2010), pp. 170\u2013177","DOI":"10.1109\/ICDMW.2010.172"},{"key":"7_CR75","doi-asserted-by":"crossref","unstructured":"K. Patroumpas, T. Sellis, Window specification over data streams, in Current Trends in Database Technology\u2013EDBT 2006 (Springer, Berlin, 2006), pp. 445\u2013464","DOI":"10.1007\/11896548_35"},{"key":"7_CR76","doi-asserted-by":"crossref","unstructured":"D. Peleg, A.A. Sch\u00e4ffer, Graph spanners. J. Graph Theory 13(1), 99\u2013116 (1989)","DOI":"10.1002\/jgt.3190130114"},{"key":"7_CR77","doi-asserted-by":"crossref","unstructured":"M.A. Shah, J.M. Hellerstein, S. Chandrasekaran, M.J. Franklin, Flux: An adaptive partitioning operator for continuous query systems, in Proceedings of the 19th International Conference on Data Engineering (IEEE, 2003), pp. 25\u201336","DOI":"10.1109\/ICDE.2003.1260779"},{"key":"7_CR78","doi-asserted-by":"crossref","unstructured":"M.A. Shah, J.M. Hellerstein, E. Brewer, Highly available, fault-tolerant, parallel dataflows, in Proceedings of the 2004 ACM SIGMOD International Conference on Management of Data (ACM, 2004), pp. 827\u2013838","DOI":"10.1145\/1007568.1007662"},{"key":"7_CR79","doi-asserted-by":"crossref","unstructured":"U. Srivastava, J. Widom, Flexible time management in data stream systems. in Proceedings of the Twenty-Third ACM SIGMOD-SIGACT-SIGART Symposium on Principles of Database Systems (ACM, 2004), pp. 263\u2013274","DOI":"10.1145\/1055558.1055596"},{"key":"7_CR80","unstructured":"StreamBase I: Streambase: Real-time, low latency data processing with a stream processing engine (2006)"},{"key":"7_CR81","unstructured":"J. Thaler, Semi-streaming algorithms for annotated graph streams (2014). arXiv preprint arXiv:1407.3462"},{"key":"7_CR82","unstructured":"The Apache APEX project, https:\/\/www.datatorrent.com\/apex\/"},{"key":"7_CR83","unstructured":"The Apache Beam System, https:\/\/wiki.apache.org\/incubator\/BeamProposal"},{"key":"7_CR84","unstructured":"The Kappa Architecture by Jay Kreps, http:\/\/milinda.pathirage.org\/kappa-architecture.com\/"},{"key":"7_CR85","unstructured":"The Trident Stream Processing Programming Model, http:\/\/storm.apache.org\/releases\/0.10.0\/Trident-tutorial.html"},{"key":"7_CR86","doi-asserted-by":"crossref","unstructured":"A. Toshniwal, S. Taneja, A. Shukla, K. Ramasamy, J.M. Patel, S. Kulkarni, J. Jackson, K. Gade, M. Fu, J. Donham et\u00a0al, Storm @ Twitter, in Proceedings of the 2014 ACM SIGMOD International Conference on Management of Data (ACM, 2014), pp. 147\u2013156","DOI":"10.1145\/2588555.2595641"},{"key":"7_CR87","doi-asserted-by":"crossref","unstructured":"J. Webber, A programmatic introduction to Neo4j, in Proceedings of the 3rd Annual Conference on Systems, Programming, and Applications: Software For Humanity (ACM, 2012), pp. 217\u2013218","DOI":"10.1145\/2384716.2384777"},{"key":"7_CR88","doi-asserted-by":"crossref","unstructured":"R.S. Xin, J.E. Gonzalez, M.J. Franklin, I. Stoica, GraphX: A resilient distributed graph system on Spark, in First International Workshop on Graph Data Management Experiences and Systems (ACM, 2013), p. 2","DOI":"10.1145\/2484425.2484427"},{"key":"7_CR89","first-page":"10","volume":"10","author":"M Zaharia","year":"2010","unstructured":"M. Zaharia, M. Chowdhury, M.J. Franklin, S. Shenker, I. Stoica, Spark: Cluster computing with working sets. HotCloud 10, 10\u201310 (2010)","journal-title":"HotCloud"},{"key":"7_CR90","doi-asserted-by":"crossref","unstructured":"M. Zaharia, T. Das, H. Li, S. Shenker, I. Stoica, 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 (USENIX Association, 2012), pp. 10\u201310","DOI":"10.21236\/ADA575859"}],"container-title":["Handbook of Big Data Technologies"],"original-title":[],"language":"en","link":[{"URL":"http:\/\/link.springer.com\/content\/pdf\/10.1007\/978-3-319-49340-4_7","content-type":"unspecified","content-version":"vor","intended-application":"similarity-checking"}],"deposited":{"date-parts":[[2020,10,3]],"date-time":"2020-10-03T03:18:58Z","timestamp":1601695138000},"score":1,"resource":{"primary":{"URL":"http:\/\/link.springer.com\/10.1007\/978-3-319-49340-4_7"}},"subtitle":[],"short-title":[],"issued":{"date-parts":[[2017]]},"ISBN":["9783319493398","9783319493404"],"references-count":90,"URL":"https:\/\/doi.org\/10.1007\/978-3-319-49340-4_7","relation":{},"subject":[],"published":{"date-parts":[[2017]]}}}