{"status":"ok","message-type":"work","message-version":"1.0.0","message":{"indexed":{"date-parts":[[2026,4,10]],"date-time":"2026-04-10T19:44:48Z","timestamp":1775850288981,"version":"3.50.1"},"publisher-location":"New York, NY, USA","reference-count":42,"publisher":"ACM","license":[{"start":{"date-parts":[[2013,11,3]],"date-time":"2013-11-03T00:00:00Z","timestamp":1383436800000},"content-version":"vor","delay-in-days":0,"URL":"https:\/\/www.acm.org\/publications\/policies\/copyright_policy#Background"}],"funder":[{"name":"Clearstory Data"},{"name":"FitWave"},{"DOI":"10.13039\/100002418","name":"Intel Corporation","doi-asserted-by":"publisher","id":[{"id":"10.13039\/100002418","id-type":"DOI","asserted-by":"publisher"}]},{"DOI":"10.13039\/100004682","name":"Oracle","doi-asserted-by":"publisher","id":[{"id":"10.13039\/100004682","id-type":"DOI","asserted-by":"publisher"}]},{"name":"VMware"},{"name":"Cloudera"},{"DOI":"10.13039\/100005801","name":"Facebook","doi-asserted-by":"publisher","id":[{"id":"10.13039\/100005801","id-type":"DOI","asserted-by":"publisher"}]},{"DOI":"10.13039\/100004358","name":"Samsung","doi-asserted-by":"publisher","id":[{"id":"10.13039\/100004358","id-type":"DOI","asserted-by":"publisher"}]},{"DOI":"10.13039\/100000185","name":"Defense Advanced Research Projects Agency","doi-asserted-by":"publisher","award":["FA8750-12-2-0331"],"award-info":[{"award-number":["FA8750-12-2-0331"]}],"id":[{"id":"10.13039\/100000185","id-type":"DOI","asserted-by":"publisher"}]},{"DOI":"10.13039\/100000143","name":"Division of Computing and Communication Foundations","doi-asserted-by":"publisher","award":["CCF-1139158"],"award-info":[{"award-number":["CCF-1139158"]}],"id":[{"id":"10.13039\/100000143","id-type":"DOI","asserted-by":"publisher"}]},{"DOI":"10.13039\/100004783","name":"SAP America","doi-asserted-by":"publisher","id":[{"id":"10.13039\/100004783","id-type":"DOI","asserted-by":"publisher"}]},{"DOI":"10.13039\/501100003816","name":"Huawei Technologies","doi-asserted-by":"publisher","id":[{"id":"10.13039\/501100003816","id-type":"DOI","asserted-by":"publisher"}]},{"DOI":"10.13039\/100004318","name":"Microsoft","doi-asserted-by":"publisher","id":[{"id":"10.13039\/100004318","id-type":"DOI","asserted-by":"publisher"}]},{"DOI":"10.13039\/100006785","name":"Google","doi-asserted-by":"publisher","id":[{"id":"10.13039\/100006785","id-type":"DOI","asserted-by":"publisher"}]},{"name":"Amazon Web Services"},{"name":"Ericsson"},{"name":"Hortonworks"},{"name":"WANdisco"},{"name":"NetApp"},{"name":"Splunk"},{"name":"Yahoo!"},{"DOI":"10.13039\/100004351","name":"Cisco Systems","doi-asserted-by":"publisher","id":[{"id":"10.13039\/100004351","id-type":"DOI","asserted-by":"publisher"}]},{"DOI":"10.13039\/100004313","name":"General Electric","doi-asserted-by":"publisher","id":[{"id":"10.13039\/100004313","id-type":"DOI","asserted-by":"publisher"}]}],"content-domain":{"domain":["dl.acm.org"],"crossmark-restriction":true},"short-container-title":[],"published-print":{"date-parts":[[2013,11,3]]},"DOI":"10.1145\/2517349.2522737","type":"proceedings-article","created":{"date-parts":[[2013,10,8]],"date-time":"2013-10-08T13:27:04Z","timestamp":1381238824000},"page":"423-438","update-policy":"https:\/\/doi.org\/10.1145\/crossmark-policy","source":"Crossref","is-referenced-by-count":720,"title":["Discretized streams"],"prefix":"10.1145","author":[{"given":"Matei","family":"Zaharia","sequence":"first","affiliation":[{"name":"University of California, Berkeley"}]},{"given":"Tathagata","family":"Das","sequence":"additional","affiliation":[{"name":"University of California, Berkeley"}]},{"given":"Haoyuan","family":"Li","sequence":"additional","affiliation":[{"name":"University of California, Berkeley"}]},{"given":"Timothy","family":"Hunter","sequence":"additional","affiliation":[{"name":"University of California, Berkeley"}]},{"given":"Scott","family":"Shenker","sequence":"additional","affiliation":[{"name":"University of California, Berkeley"}]},{"given":"Ion","family":"Stoica","sequence":"additional","affiliation":[{"name":"University of California, Berkeley"}]}],"member":"320","published-online":{"date-parts":[[2013,11,3]]},"reference":[{"key":"e_1_3_2_2_1_1","doi-asserted-by":"publisher","DOI":"10.14778\/2536222.2536229"},{"key":"e_1_3_2_2_2_1","doi-asserted-by":"publisher","DOI":"10.14778\/1687553.1687590"},{"key":"e_1_3_2_2_3_1","unstructured":"Apache Flume. http:\/\/incubator.apache.org\/flume\/.  Apache Flume. http:\/\/incubator.apache.org\/flume\/."},{"key":"e_1_3_2_2_4_1","doi-asserted-by":"publisher","DOI":"10.1145\/872757.872854"},{"key":"e_1_3_2_2_5_1","doi-asserted-by":"publisher","DOI":"10.1145\/1331904.1331907"},{"key":"e_1_3_2_2_6_1","doi-asserted-by":"publisher","DOI":"10.1145\/2038916.2038923"},{"key":"e_1_3_2_2_7_1","doi-asserted-by":"publisher","DOI":"10.5555\/1287369.1287389"},{"key":"e_1_3_2_2_8_1","volume-title":"CIDR","author":"Chandrasekaran S.","year":"2003","unstructured":"S. Chandrasekaran , O. Cooper , A. Deshpande , M. J. Franklin , J. M. Hellerstein , W. Hong , S. Krishnamurthy , S. Madden , V. Raman , F. Reiss , and M. Shah . TelegraphCQ: Continuous dataflow processing for an uncertain world . In CIDR , 2003 . S. Chandrasekaran, O. Cooper, A. Deshpande, M. J. Franklin, J. M. Hellerstein, W. Hong, S. Krishnamurthy, S. Madden, V. Raman, F. Reiss, and M. Shah. TelegraphCQ: Continuous dataflow processing for an uncertain world. In CIDR, 2003."},{"key":"e_1_3_2_2_9_1","volume-title":"CIDR","author":"Cherniack M.","year":"2003","unstructured":"M. Cherniack , H. Balakrishnan , M. Balazinska , D. Carney , U. Cetintemel , Y. Xing , and S. B. Zdonik . Scalable distributed stream processing . In CIDR , 2003 . M. Cherniack, H. Balakrishnan, M. Balazinska, D. Carney, U. Cetintemel, Y. Xing, and S. B. Zdonik. Scalable distributed stream processing. In CIDR, 2003."},{"key":"e_1_3_2_2_10_1","volume-title":"NSDI","author":"Condie T.","year":"2010","unstructured":"T. Condie , N. Conway , P. Alvaro , and J. M. Hellerstein . MapReduce online . NSDI , 2010 . T. Condie, N. Conway, P. Alvaro, and J. M. Hellerstein. MapReduce online. NSDI, 2010."},{"key":"e_1_3_2_2_11_1","volume-title":"OSDI","author":"Dean J.","year":"2004","unstructured":"J. Dean and S. Ghemawat . MapReduce: Simplified data processing on large clusters . In OSDI , 2004 . J. Dean and S. Ghemawat. MapReduce: Simplified data processing on large clusters. In OSDI, 2004."},{"key":"e_1_3_2_2_12_1","unstructured":"EsperTech. Performance-related information. http:\/\/esper.codehaus.org\/esper\/performance\/performance.html Retrieved March 2013.  EsperTech. Performance-related information. http:\/\/esper.codehaus.org\/esper\/performance\/performance.html Retrieved March 2013."},{"key":"e_1_3_2_2_13_1","volume-title":"Retrieved","year":"2013","unstructured":"EsperTech. Tutorial. http:\/\/esper.codehaus.org\/tutorials\/tutorial\/tutorial.html , Retrieved March 2013 . EsperTech. Tutorial. http:\/\/esper.codehaus.org\/tutorials\/tutorial\/tutorial.html, Retrieved March 2013."},{"key":"e_1_3_2_2_14_1","volume-title":"CIDR","author":"Franklin M.","year":"2009","unstructured":"M. Franklin , S. Krishnamurthy , N. Conway , A. Li , A. Russakovsky , and N. Thombre . Continuous analytics: Rethinking query processing in a network-effect world . CIDR , 2009 . M. Franklin, S. Krishnamurthy, N. Conway, A. Li, A. Russakovsky, and N. Thombre. Continuous analytics: Rethinking query processing in a network-effect world. CIDR, 2009."},{"key":"e_1_3_2_2_15_1","doi-asserted-by":"publisher","DOI":"10.1145\/945445.945450"},{"key":"e_1_3_2_2_16_1","unstructured":"J. Hammerbacher. Who is using flume in production? http:\/\/www.quora.com\/Flume\/Who-is-using-Flume-in-production\/answer\/Jeff-Hammerbacher.  J. Hammerbacher. Who is using flume in production? http:\/\/www.quora.com\/Flume\/Who-is-using-Flume-in-production\/answer\/Jeff-Hammerbacher."},{"key":"e_1_3_2_2_17_1","doi-asserted-by":"publisher","DOI":"10.1145\/1807128.1807139"},{"key":"e_1_3_2_2_18_1","doi-asserted-by":"publisher","DOI":"10.1145\/2038916.2038944"},{"key":"e_1_3_2_2_19_1","doi-asserted-by":"publisher","DOI":"10.1109\/ICDE.2005.72"},{"key":"e_1_3_2_2_20_1","doi-asserted-by":"publisher","DOI":"10.1109\/ICDE.2007.367863"},{"key":"e_1_3_2_2_21_1","doi-asserted-by":"publisher","DOI":"10.1145\/1272996.1273005"},{"key":"e_1_3_2_2_22_1","doi-asserted-by":"publisher","DOI":"10.1145\/1807167.1807290"},{"key":"e_1_3_2_2_23_1","doi-asserted-by":"publisher","DOI":"10.1145\/1807128.1807138"},{"key":"e_1_3_2_2_24_1","volume-title":"USENIX ATC","author":"Logothetis D.","year":"2011","unstructured":"D. Logothetis , C. Trezzo , K. C. Webb , and K. Yocum . In-situ MapReduce for log processing . In USENIX ATC , 2011 . D. Logothetis, C. Trezzo, K. C. Webb, and K. Yocum. In-situ MapReduce for log processing. In USENIX ATC, 2011."},{"key":"e_1_3_2_2_25_1","unstructured":"N. Marz. Trident: a high-level abstraction for realtime computation. http:\/\/engineering.twitter.com\/2012\/08\/trident-high-level-abstraction-for.html.  N. Marz. Trident: a high-level abstraction for realtime computation. http:\/\/engineering.twitter.com\/2012\/08\/trident-high-level-abstraction-for.html."},{"key":"e_1_3_2_2_26_1","volume-title":"Conference on Innovative Data Systems Research (CIDR)","author":"McSherry F.","year":"2013","unstructured":"F. McSherry , D. G. Murray , R. Isaacs , and M. Isard . Differential dataflow . In Conference on Innovative Data Systems Research (CIDR) , 2013 . F. McSherry, D. G. Murray, R. Isaacs, and M. Isard. Differential dataflow. In Conference on Innovative Data Systems Research (CIDR), 2013."},{"key":"e_1_3_2_2_27_1","doi-asserted-by":"publisher","DOI":"10.1145\/2517349.2522738"},{"key":"e_1_3_2_2_28_1","doi-asserted-by":"publisher","DOI":"10.1109\/ICDMW.2010.172"},{"key":"e_1_3_2_2_29_1","doi-asserted-by":"publisher","DOI":"10.1145\/2043556.2043560"},{"key":"e_1_3_2_2_30_1","unstructured":"Oracle. Oracle complex event processing performance. http:\/\/www.oracle.com\/technetwork\/middleware\/complex-event-processing\/overview\/cepperformancewhitepaper-128060.pdf 2008.  Oracle. Oracle complex event processing performance. http:\/\/www.oracle.com\/technetwork\/middleware\/complex-event-processing\/overview\/cepperformancewhitepaper-128060.pdf 2008."},{"key":"e_1_3_2_2_31_1","volume-title":"OSDI","author":"Peng D.","year":"2010","unstructured":"D. Peng and F. Dabek . Large-scale incremental processing using distributed transactions and notifications . In OSDI 2010 . D. Peng and F. Dabek. Large-scale incremental processing using distributed transactions and notifications. In OSDI 2010."},{"key":"e_1_3_2_2_32_1","doi-asserted-by":"publisher","DOI":"10.1145\/2465351.2465353"},{"key":"e_1_3_2_2_33_1","doi-asserted-by":"publisher","DOI":"10.1145\/1007568.1007662"},{"key":"e_1_3_2_2_34_1","volume-title":"XLDB 2011","author":"Shao Z.","year":"2011","unstructured":"Z. Shao . Real-time analytics at Facebook . XLDB 2011 , http:\/\/www-conf.slac.stanford.edu\/xldb 2011 \/talks\/xldb2011_tue_0940_facebookrealtimeanalytics.pdf. Z. Shao. Real-time analytics at Facebook. XLDB 2011, http:\/\/www-conf.slac.stanford.edu\/xldb2011\/talks\/xldb2011_tue_0940_facebookrealtimeanalytics.pdf."},{"key":"e_1_3_2_2_35_1","doi-asserted-by":"publisher","DOI":"10.1145\/1055558.1055596"},{"key":"e_1_3_2_2_36_1","unstructured":"Storm. https:\/\/github.com\/nathanmarz\/storm\/wiki.  Storm. https:\/\/github.com\/nathanmarz\/storm\/wiki."},{"key":"e_1_3_2_2_37_1","unstructured":"Guaranteed message processing (Storm wiki). https:\/\/github.com\/nathanmarz\/storm\/wiki\/Guaranteeing-message-processing.  Guaranteed message processing (Storm wiki). https:\/\/github.com\/nathanmarz\/storm\/wiki\/Guaranteeing-message-processing."},{"key":"e_1_3_2_2_38_1","doi-asserted-by":"publisher","DOI":"10.1109\/SP.2011.25"},{"key":"e_1_3_2_2_39_1","volume-title":"http:\/\/www.streambase.com\/wp-content\/uploads\/downloads\/StreamBase_White_Paper_Performance_and_Scalability_Characterization.pdf","author":"Tibbetts R.","year":"2009","unstructured":"R. Tibbetts . Streambase performance & scalability characterization. http:\/\/www.streambase.com\/wp-content\/uploads\/downloads\/StreamBase_White_Paper_Performance_and_Scalability_Characterization.pdf , 2009 . R. Tibbetts. Streambase performance & scalability characterization. http:\/\/www.streambase.com\/wp-content\/uploads\/downloads\/StreamBase_White_Paper_Performance_and_Scalability_Characterization.pdf, 2009."},{"key":"e_1_3_2_2_40_1","doi-asserted-by":"publisher","DOI":"10.1109\/IPDPS.2012.108"},{"key":"e_1_3_2_2_41_1","volume-title":"OSDI '08","author":"Yu Y.","year":"2008","unstructured":"Y. Yu , M. Isard , D. Fetterly , M. Budiu , \u00da. Erlingsson, P. K. Gunda , and J. Currey . DryadLINQ: A system for general-purpose distributed data-parallel computing using a high-level language . In OSDI '08 , 2008 . Y. Yu, M. Isard, D. Fetterly, M. Budiu, \u00da. Erlingsson, P. K. Gunda, and J. Currey. DryadLINQ: A system for general-purpose distributed data-parallel computing using a high-level language. In OSDI '08, 2008."},{"key":"e_1_3_2_2_42_1","volume-title":"NSDI","author":"Zaharia M.","year":"2012","unstructured":"M. Zaharia , M. Chowdhury , T. Das , A. Dave , J. Ma , M. McCauley , M. Franklin , S. Shenker , and I. Stoica . Resilient distributed datasets: A fault-tolerant abstraction for in-memory cluster computing . In NSDI , 2012 . M. Zaharia, M. Chowdhury, T. Das, A. Dave, J. Ma, M. McCauley, M. Franklin, S. Shenker, and I. Stoica. Resilient distributed datasets: A fault-tolerant abstraction for in-memory cluster computing. In NSDI, 2012."}],"event":{"name":"SOSP '13: ACM SIGOPS 24th Symposium on Operating Systems Principles","location":"Farminton Pennsylvania","acronym":"SOSP '13","sponsor":["SIGOPS ACM Special Interest Group on Operating Systems"]},"container-title":["Proceedings of the Twenty-Fourth ACM Symposium on Operating Systems Principles"],"original-title":[],"link":[{"URL":"https:\/\/dl.acm.org\/doi\/10.1145\/2517349.2522737","content-type":"unspecified","content-version":"vor","intended-application":"text-mining"},{"URL":"https:\/\/dl.acm.org\/doi\/pdf\/10.1145\/2517349.2522737","content-type":"unspecified","content-version":"vor","intended-application":"similarity-checking"}],"deposited":{"date-parts":[[2025,6,18]],"date-time":"2025-06-18T07:28:53Z","timestamp":1750231733000},"score":1,"resource":{"primary":{"URL":"https:\/\/dl.acm.org\/doi\/10.1145\/2517349.2522737"}},"subtitle":["fault-tolerant streaming computation at scale"],"short-title":[],"issued":{"date-parts":[[2013,11,3]]},"references-count":42,"alternative-id":["10.1145\/2517349.2522737","10.1145\/2517349"],"URL":"https:\/\/doi.org\/10.1145\/2517349.2522737","relation":{},"subject":[],"published":{"date-parts":[[2013,11,3]]},"assertion":[{"value":"2013-11-03","order":2,"name":"published","label":"Published","group":{"name":"publication_history","label":"Publication History"}}]}}