{"status":"ok","message-type":"work","message-version":"1.0.0","message":{"indexed":{"date-parts":[[2025,3,26]],"date-time":"2025-03-26T14:21:51Z","timestamp":1742998911536,"version":"3.40.3"},"publisher-location":"Cham","reference-count":18,"publisher":"Springer International Publishing","isbn-type":[{"type":"print","value":"9783030675394"},{"type":"electronic","value":"9783030675400"}],"license":[{"start":{"date-parts":[[2021,1,1]],"date-time":"2021-01-01T00:00:00Z","timestamp":1609459200000},"content-version":"tdm","delay-in-days":0,"URL":"http:\/\/www.springer.com\/tdm"},{"start":{"date-parts":[[2021,1,1]],"date-time":"2021-01-01T00:00:00Z","timestamp":1609459200000},"content-version":"vor","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":[[2021]]},"DOI":"10.1007\/978-3-030-67540-0_28","type":"book-chapter","created":{"date-parts":[[2021,1,21]],"date-time":"2021-01-21T13:12:57Z","timestamp":1611234777000},"page":"444-454","update-policy":"https:\/\/doi.org\/10.1007\/springer_crossmark_policy","source":"Crossref","is-referenced-by-count":0,"title":["Toward Sliding Time Window of Low Watermark to Detect Delayed Stream Arrival"],"prefix":"10.1007","author":[{"given":"Xiaoqian","family":"Zhang","sequence":"first","affiliation":[],"role":[{"role":"author","vocabulary":"crossref"}]},{"ORCID":"https:\/\/orcid.org\/0000-0002-0135-5423","authenticated-orcid":false,"given":"Kun","family":"Ma","sequence":"additional","affiliation":[],"role":[{"role":"author","vocabulary":"crossref"}]}],"member":"297","published-online":{"date-parts":[[2021,1,22]]},"reference":[{"issue":"11","key":"28_CR1","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 Endow. 6(11), 1033\u20131044 (2013)","journal-title":"Proc. VLDB Endow."},{"key":"28_CR2","unstructured":"Awad, A., Traub, J., Sakr, S.: Adaptive watermarks: a concept drift-based approach for predicting event-time progress in data streams. In: EDBT, pp. 622\u2013625 (2019)"},{"issue":"12","key":"28_CR3","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\u00ae: consistent stateful distributed stream processing. Proc. VLDB Endow. 10(12), 1718\u20131729 (2017)","journal-title":"Proc. VLDB Endow."},{"key":"28_CR4","doi-asserted-by":"publisher","first-page":"219","DOI":"10.1007\/978-3-319-49340-4_7","volume-title":"Handbook of Big Data Technologies","author":"P Carbone","year":"2017","unstructured":"Carbone, P., et al.: Large-scale data stream processing systems. In: Zomaya, A.Y., Sakr, S. (eds.) Handbook of Big Data Technologies, pp. 219\u2013260. Springer, Cham (2017). https:\/\/doi.org\/10.1007\/978-3-319-49340-4_7"},{"issue":"4","key":"28_CR5","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 (2015)","journal-title":"Bull. IEEE Comput. Soc. Tech. Comm. Data Eng."},{"issue":"4","key":"28_CR6","doi-asserted-by":"publisher","first-page":"954","DOI":"10.1109\/TC.2013.15","volume":"63","author":"Q Chen","year":"2013","unstructured":"Chen, Q., Liu, C., Xiao, Z.: Improving MapReduce performance using smart speculative execution strategy. IEEE Trans. Comput. 63(4), 954\u2013967 (2013)","journal-title":"IEEE Trans. Comput."},{"key":"28_CR7","unstructured":"Grulich, P.M., Saitenmacher, R., Traub, J., Bre\u00df, S., Rabl, T., Markl, V.: Scalable detection of concept drifts on data streams with parallel adaptive windowing. In: EDBT, pp. 477\u2013480 (2018)"},{"key":"28_CR8","unstructured":"Hwang, J.H., Balazinska, M., Rasin, A., Cetintemel, U., Stonebraker, M., Zdonik, S.: High-availability algorithms for distributed stream processing. In: 21st International Conference on Data Engineering (ICDE 2005), pp. 779\u2013790. IEEE (2005)"},{"issue":"1","key":"28_CR9","doi-asserted-by":"publisher","first-page":"9","DOI":"10.14445\/22312803\/IJCTT-V19P103","volume":"19","author":"MH Iqbal","year":"2015","unstructured":"Iqbal, M.H., Soomro, T.R.: Big data analysis: Apache storm perspective. Int. J. Comput. Trends Technol. 19(1), 9\u201314 (2015)","journal-title":"Int. J. Comput. Trends Technol."},{"key":"28_CR10","doi-asserted-by":"crossref","unstructured":"Jerzak, Z., Heinze, T., Fehr, M., Gr\u00f6ber, D., Hartung, R., Stojanovic, N.: The debs 2012 grand challenge. In: Proceedings of the 6th ACM International Conference on Distributed Event-Based Systems, pp. 393\u2013398. ACM (2012)","DOI":"10.1145\/2335484.2335536"},{"issue":"1","key":"28_CR11","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":"28_CR12","doi-asserted-by":"crossref","unstructured":"Nagano, K., Itokawa, T., Kitasuka, T., Aritsugi, M.: Exploitation of backup nodes for reducing recovery cost in high availability stream processing systems. In: Proceedings of the Fourteenth International Database Engineering & Applications Symposium, pp. 61\u201363. ACM (2010)","DOI":"10.1145\/1866480.1866490"},{"key":"28_CR13","doi-asserted-by":"crossref","unstructured":"Shah, M.A., Hellerstein, J.M., Brewer, E.: Highly available, fault-tolerant, parallel dataflows. In: Proceedings of the 2004 ACM SIGMOD International Conference on Management of Data, pp. 827\u2013838. ACM (2004)","DOI":"10.1145\/1007568.1007662"},{"key":"28_CR14","first-page":"7","volume":"15","author":"AG Shoro","year":"2015","unstructured":"Shoro, A.G., Soomro, T.R.: Big data analysis: Apache spark perspective. Glob. J. Comput. Sci. Technol. 15, 7 (2015)","journal-title":"Glob. J. Comput. Sci. Technol."},{"key":"28_CR15","doi-asserted-by":"crossref","unstructured":"Toshniwal, A., et al.: Storm@ twitter. In: Proceedings of the 2014 ACM SIGMOD International Conference on Management of Data, pp. 147\u2013156. ACM (2014)","DOI":"10.1145\/2588555.2595641"},{"key":"28_CR16","doi-asserted-by":"crossref","unstructured":"Traub, J., et al.: Scotty: efficient window aggregation for out-of-order stream processing. In: 2018 IEEE 34th International Conference on Data Engineering (ICDE), pp. 1300\u20131303. IEEE (2018)","DOI":"10.1109\/ICDE.2018.00135"},{"key":"28_CR17","doi-asserted-by":"crossref","unstructured":"Weiss, W., Jim\u00e9nez, V.J.E., Zeiner, H.: A dataset and a comparison of out-of-order event compensation algorithms. In: IoTBDS, pp. 36\u201346 (2017)","DOI":"10.5220\/0006235400360046"},{"key":"28_CR18","doi-asserted-by":"crossref","unstructured":"Zaharia, M., Das, T., Li, H., Hunter, T., Shenker, S., Stoica, I.: Discretized streams: fault-tolerant streaming computation at scale. In: Proceedings of the Twenty-Fourth ACM Symposium on Operating Systems Principles, pp. 423\u2013438. ACM (2013)","DOI":"10.1145\/2517349.2522737"}],"container-title":["Lecture Notes of the Institute for Computer Sciences, Social Informatics and Telecommunications Engineering","Collaborative Computing: Networking, Applications and Worksharing"],"original-title":[],"language":"en","link":[{"URL":"https:\/\/link.springer.com\/content\/pdf\/10.1007\/978-3-030-67540-0_28","content-type":"unspecified","content-version":"vor","intended-application":"similarity-checking"}],"deposited":{"date-parts":[[2022,12,12]],"date-time":"2022-12-12T17:03:44Z","timestamp":1670864624000},"score":1,"resource":{"primary":{"URL":"https:\/\/link.springer.com\/10.1007\/978-3-030-67540-0_28"}},"subtitle":[],"short-title":[],"issued":{"date-parts":[[2021]]},"ISBN":["9783030675394","9783030675400"],"references-count":18,"URL":"https:\/\/doi.org\/10.1007\/978-3-030-67540-0_28","relation":{},"ISSN":["1867-8211","1867-822X"],"issn-type":[{"type":"print","value":"1867-8211"},{"type":"electronic","value":"1867-822X"}],"subject":[],"published":{"date-parts":[[2021]]},"assertion":[{"value":"22 January 2021","order":1,"name":"first_online","label":"First Online","group":{"name":"ChapterHistory","label":"Chapter History"}},{"value":"CollaborateCom","order":1,"name":"conference_acronym","label":"Conference Acronym","group":{"name":"ConferenceInfo","label":"Conference Information"}},{"value":"International Conference on Collaborative Computing: Networking, Applications and Worksharing","order":2,"name":"conference_name","label":"Conference Name","group":{"name":"ConferenceInfo","label":"Conference Information"}},{"value":"Shanghai","order":3,"name":"conference_city","label":"Conference City","group":{"name":"ConferenceInfo","label":"Conference Information"}},{"value":"China","order":4,"name":"conference_country","label":"Conference Country","group":{"name":"ConferenceInfo","label":"Conference Information"}},{"value":"2020","order":5,"name":"conference_year","label":"Conference Year","group":{"name":"ConferenceInfo","label":"Conference Information"}},{"value":"16 October 2020","order":7,"name":"conference_start_date","label":"Conference Start Date","group":{"name":"ConferenceInfo","label":"Conference Information"}},{"value":"18 October 2020","order":8,"name":"conference_end_date","label":"Conference End Date","group":{"name":"ConferenceInfo","label":"Conference Information"}},{"value":"16","order":9,"name":"conference_number","label":"Conference Number","group":{"name":"ConferenceInfo","label":"Conference Information"}},{"value":"colcom2020","order":10,"name":"conference_id","label":"Conference ID","group":{"name":"ConferenceInfo","label":"Conference Information"}},{"value":"https:\/\/collaboratecom.eai-conferences.org\/2020\/","order":11,"name":"conference_url","label":"Conference URL","group":{"name":"ConferenceInfo","label":"Conference Information"}},{"value":"Double-blind","order":1,"name":"type","label":"Type","group":{"name":"ConfEventPeerReviewInformation","label":"Peer Review Information (provided by the conference organizers)"}},{"value":"Confy+","order":2,"name":"conference_management_system","label":"Conference Management System","group":{"name":"ConfEventPeerReviewInformation","label":"Peer Review Information (provided by the conference organizers)"}},{"value":"211","order":3,"name":"number_of_submissions_sent_for_review","label":"Number of Submissions Sent for Review","group":{"name":"ConfEventPeerReviewInformation","label":"Peer Review Information (provided by the conference organizers)"}},{"value":"61","order":4,"name":"number_of_full_papers_accepted","label":"Number of Full Papers Accepted","group":{"name":"ConfEventPeerReviewInformation","label":"Peer Review Information (provided by the conference organizers)"}},{"value":"16","order":5,"name":"number_of_short_papers_accepted","label":"Number of Short Papers Accepted","group":{"name":"ConfEventPeerReviewInformation","label":"Peer Review Information (provided by the conference organizers)"}},{"value":"29% - The value is computed by the equation \"Number of Full Papers Accepted \/ Number of Submissions Sent for Review * 100\" and then rounded to a whole number.","order":6,"name":"acceptance_rate_of_full_papers","label":"Acceptance Rate of Full Papers","group":{"name":"ConfEventPeerReviewInformation","label":"Peer Review Information (provided by the conference organizers)"}},{"value":"3","order":7,"name":"average_number_of_reviews_per_paper","label":"Average Number of Reviews per Paper","group":{"name":"ConfEventPeerReviewInformation","label":"Peer Review Information (provided by the conference organizers)"}},{"value":"No","order":9,"name":"external_reviewers_involved","label":"External Reviewers Involved","group":{"name":"ConfEventPeerReviewInformation","label":"Peer Review Information (provided by the conference organizers)"}},{"value":"The conference was held virtually due to COVID-19 pandemic.","order":10,"name":"additional_info_on_review_process","label":"Additional Info on Review Process","group":{"name":"ConfEventPeerReviewInformation","label":"Peer Review Information (provided by the conference organizers)"}}]}}