{"status":"ok","message-type":"work","message-version":"1.0.0","message":{"indexed":{"date-parts":[[2025,6,18]],"date-time":"2025-06-18T04:35:23Z","timestamp":1750221323860,"version":"3.41.0"},"publisher-location":"New York, NY, USA","reference-count":22,"publisher":"ACM","license":[{"start":{"date-parts":[[2017,9,23]],"date-time":"2017-09-23T00:00:00Z","timestamp":1506124800000},"content-version":"vor","delay-in-days":0,"URL":"https:\/\/www.acm.org\/publications\/policies\/copyright_policy#Background"}],"content-domain":{"domain":["dl.acm.org"],"crossmark-restriction":true},"short-container-title":[],"published-print":{"date-parts":[[2017,9,23]]},"DOI":"10.1145\/3131704.3131724","type":"proceedings-article","created":{"date-parts":[[2017,9,27]],"date-time":"2017-09-27T12:34:00Z","timestamp":1506515640000},"page":"1-6","update-policy":"https:\/\/doi.org\/10.1145\/crossmark-policy","source":"Crossref","is-referenced-by-count":0,"title":["Fast and Precise recovery in Stream processing based on Distributed Cache"],"prefix":"10.1145","author":[{"given":"Yingying","family":"Zheng","sequence":"first","affiliation":[{"name":"Institute of Software, Chinese Academy of Sciences"}],"role":[{"role":"author","vocabulary":"crossref"}]},{"given":"Wei","family":"Wang","sequence":"additional","affiliation":[{"name":"Institute of Software, Chinese Academy of Sciences"}],"role":[{"role":"author","vocabulary":"crossref"}]},{"given":"Lijie","family":"Xu","sequence":"additional","affiliation":[{"name":"Institute of Software, Chinese Academy of Sciences"}],"role":[{"role":"author","vocabulary":"crossref"}]},{"given":"Zhen","family":"Tang","sequence":"additional","affiliation":[{"name":"Institute of Software, Chinese Academy of Sciences"}],"role":[{"role":"author","vocabulary":"crossref"}]},{"given":"Zhongshan","family":"Ren","sequence":"additional","affiliation":[{"name":"Institute of Software, Chinese Academy of Sciences"}],"role":[{"role":"author","vocabulary":"crossref"}]},{"given":"Jun","family":"Wei","sequence":"additional","affiliation":[{"name":"Institute of Software, Chinese Academy of Sciences"}],"role":[{"role":"author","vocabulary":"crossref"}]},{"given":"Dan","family":"Ye","sequence":"additional","affiliation":[{"name":"Institute of Software, Chinese Academy of Sciences"}],"role":[{"role":"author","vocabulary":"crossref"}]}],"member":"320","published-online":{"date-parts":[[2017,9,23]]},"reference":[{"key":"e_1_3_2_1_1_1","volume-title":"Big data: The next frontier for innovation, competition, and productivity[J]","author":"Manyika J","year":"2011","unstructured":"Manyika J , Chui M , Brown B , Big data: The next frontier for innovation, competition, and productivity[J] . 2011 . Manyika J, Chui M, Brown B, et al. Big data: The next frontier for innovation, competition, and productivity[J]. 2011."},{"key":"e_1_3_2_1_2_1","volume-title":"Survey of distributed stream processing for large stream sources. Technical report","author":"Kamburugamuve","year":"2013","unstructured":"Kamburugamuve , Supun, Survey of distributed stream processing for large stream sources. Technical report . 2013 . Kamburugamuve, Supun, et al. Survey of distributed stream processing for large stream sources. Technical report. 2013."},{"issue":"2","key":"e_1_3_2_1_3_1","first-page":"318","volume":"52","author":"Cui X C","year":"2015","unstructured":"Cui X C , Yu X H , Liu Y , Distributed stream processing: a survey. Journal of computer Research and Development , 2015 , 52 ( 2 ): 318 ~332. Cui X C, Yu X H, Liu Y, et al. Distributed stream processing: a survey. Journal of computer Research and Development, 2015, 52(2): 318~332.","journal-title":"Research and Development"},{"key":"e_1_3_2_1_4_1","doi-asserted-by":"publisher","DOI":"10.1145\/2528412"},{"volume-title":"ACM","author":"Castro Fernandez R","key":"e_1_3_2_1_5_1","unstructured":"Castro Fernandez R , Migliavacca M , Kalyvianaki E , Integrating scale out and fault tolerance in stream processing using operator state management[C]\/\/Proceedings of the 2013 ACM SIGMOD international conference on Management of data . ACM , 2013: 725--736. Castro Fernandez R, Migliavacca M, Kalyvianaki E, et al. Integrating scale out and fault tolerance in stream processing using operator state management[C]\/\/Proceedings of the 2013 ACM SIGMOD international conference on Management of data. ACM, 2013: 725--736."},{"key":"e_1_3_2_1_6_1","unstructured":"Apache Flink. [Online]. http:\/\/data-artisans.com\/high-throughput-low-latency-and-exactly-once-stream-processing-with-apache-flink\/.  Apache Flink. [Online]. http:\/\/data-artisans.com\/high-throughput-low-latency-and-exactly-once-stream-processing-with-apache-flink\/."},{"key":"e_1_3_2_1_7_1","unstructured":"Apache Storm. Trident API Overview. [Online]. http:\/\/storm.apache.org\/documentation\/Trident-API-Overview.html.  Apache Storm. Trident API Overview. [Online]. http:\/\/storm.apache.org\/documentation\/Trident-API-Overview.html."},{"key":"e_1_3_2_1_8_1","unstructured":"Perry F. Sneak peek: Google cloud dataflow a cloud-native data processing service[J]. URL: http:\/\/googlecloudplatform.blogspot.com\/2014\/06\/sneak-peek-googlecloud-dataflow-a-cloud-native-dataprocessing-service.html 2014.  Perry F. Sneak peek: Google cloud dataflow a cloud-native data processing service[J]. URL: http:\/\/googlecloudplatform.blogspot.com\/2014\/06\/sneak-peek-googlecloud-dataflow-a-cloud-native-dataprocessing-service.html 2014."},{"key":"e_1_3_2_1_9_1","unstructured":"Apache Flink. [online]. https:\/\/flink.apache.org\/.  Apache Flink. [online]. https:\/\/flink.apache.org\/."},{"key":"e_1_3_2_1_10_1","volume-title":"Lightweight Asynchronous Snapshots for Distributed Dataflows,\" arXiv preprint arXiv:1506.08603","author":"Carbone G.","year":"2015","unstructured":"P. Carbone , G. F\u00f3ra , S. Ewen , S. Haridi , and K. Tzoumas , \" Lightweight Asynchronous Snapshots for Distributed Dataflows,\" arXiv preprint arXiv:1506.08603 , 2015 . P. Carbone, G. F\u00f3ra, S. Ewen, S. Haridi, and K. Tzoumas, \"Lightweight Asynchronous Snapshots for Distributed Dataflows,\" arXiv preprint arXiv:1506.08603, 2015."},{"key":"e_1_3_2_1_11_1","unstructured":"Hazelcast. [online]. http:\/\/docs.hazelcast.org\/docs.  Hazelcast. [online]. http:\/\/docs.hazelcast.org\/docs."},{"key":"e_1_3_2_1_12_1","unstructured":"Apache spark streaming. [online]. http:\/\/spark.apache.org\/streaming\/.  Apache spark streaming. [online]. http:\/\/spark.apache.org\/streaming\/."},{"key":"e_1_3_2_1_13_1","doi-asserted-by":"publisher","DOI":"10.1145\/2517349.2522737"},{"key":"e_1_3_2_1_14_1","unstructured":"Apache Kafka.[online].http:\/\/kafka.apache.org\/.  Apache Kafka.[online].http:\/\/kafka.apache.org\/."},{"key":"e_1_3_2_1_15_1","doi-asserted-by":"publisher","DOI":"10.1007\/978-1-4842-1004-8_11"},{"key":"e_1_3_2_1_16_1","doi-asserted-by":"publisher","DOI":"10.21236\/ADA575859"},{"key":"e_1_3_2_1_17_1","doi-asserted-by":"publisher","DOI":"10.1145\/214451.214456"},{"key":"e_1_3_2_1_18_1","unstructured":"HDFS.[online].http:\/\/hadoop.apache.org\/docs\/current\/hadoop-project-dist\/hadoop-hdfs\/HdfsUserGuide.html.  HDFS.[online].http:\/\/hadoop.apache.org\/docs\/current\/hadoop-project-dist\/hadoop-hdfs\/HdfsUserGuide.html."},{"key":"e_1_3_2_1_19_1","unstructured":"RocksDB.[online].http:\/\/rocksdb.org.  RocksDB.[online].http:\/\/rocksdb.org."},{"key":"e_1_3_2_1_20_1","unstructured":"Spark Streaming. [online]. https:\/\/databricks.com\/blog\/2015\/01\/15\/improved-driver-fault-tolerance-and-zero-data-loss-in-spark-streaming.html.  Spark Streaming. [online]. https:\/\/databricks.com\/blog\/2015\/01\/15\/improved-driver-fault-tolerance-and-zero-data-loss-in-spark-streaming.html."},{"key":"e_1_3_2_1_21_1","volume-title":"Apache flink: Stream and batch processing in a single engine","author":"Carbone S.","year":"2015","unstructured":"P. Carbone , S. Ewen , S. Haridi , A. Katsifodimos , V. Markl , and K. Tzoumas . Apache flink: Stream and batch processing in a single engine . IEEE Data Engineering Bulletin , 2015 . P. Carbone, S. Ewen, S. Haridi, A. Katsifodimos, V. Markl, and K. Tzoumas. Apache flink: Stream and batch processing in a single engine. IEEE Data Engineering Bulletin, 2015."},{"key":"e_1_3_2_1_22_1","unstructured":"Khan Iqbal. \"Distributed Caching On The Path To Scalability\". MSDN (July 2009). Retrieved 2012-03-30.  Khan Iqbal. \"Distributed Caching On The Path To Scalability\". MSDN (July 2009). Retrieved 2012-03-30."}],"event":{"name":"Internetware'17: The Eighth Asia-Pacific Symposium on Internetware","sponsor":["Fudan University","SIGSOFT ACM Special Interest Group on Software Engineering","CCF China Computer Federation"],"location":"Shanghai China","acronym":"Internetware'17"},"container-title":["Proceedings of the 9th Asia-Pacific Symposium on Internetware"],"original-title":[],"link":[{"URL":"https:\/\/dl.acm.org\/doi\/10.1145\/3131704.3131724","content-type":"unspecified","content-version":"vor","intended-application":"text-mining"},{"URL":"https:\/\/dl.acm.org\/doi\/pdf\/10.1145\/3131704.3131724","content-type":"unspecified","content-version":"vor","intended-application":"similarity-checking"}],"deposited":{"date-parts":[[2025,6,18]],"date-time":"2025-06-18T02:13:58Z","timestamp":1750212838000},"score":1,"resource":{"primary":{"URL":"https:\/\/dl.acm.org\/doi\/10.1145\/3131704.3131724"}},"subtitle":[],"short-title":[],"issued":{"date-parts":[[2017,9,23]]},"references-count":22,"alternative-id":["10.1145\/3131704.3131724","10.1145\/3131704"],"URL":"https:\/\/doi.org\/10.1145\/3131704.3131724","relation":{},"subject":[],"published":{"date-parts":[[2017,9,23]]},"assertion":[{"value":"2017-09-23","order":2,"name":"published","label":"Published","group":{"name":"publication_history","label":"Publication History"}}]}}