{"status":"ok","message-type":"work","message-version":"1.0.0","message":{"indexed":{"date-parts":[[2025,5,4]],"date-time":"2025-05-04T00:38:19Z","timestamp":1746319099759},"reference-count":20,"publisher":"Springer Science and Business Media LLC","issue":"6","license":[{"start":{"date-parts":[[2021,7,18]],"date-time":"2021-07-18T00:00:00Z","timestamp":1626566400000},"content-version":"tdm","delay-in-days":0,"URL":"https:\/\/www.springernature.com\/gp\/researchers\/text-and-data-mining"},{"start":{"date-parts":[[2021,7,18]],"date-time":"2021-07-18T00:00:00Z","timestamp":1626566400000},"content-version":"vor","delay-in-days":0,"URL":"https:\/\/www.springernature.com\/gp\/researchers\/text-and-data-mining"}],"content-domain":{"domain":["link.springer.com"],"crossmark-restriction":false},"short-container-title":["Front. Comput. Sci."],"published-print":{"date-parts":[[2021,12]]},"DOI":"10.1007\/s11704-020-0206-7","type":"journal-article","created":{"date-parts":[[2021,7,18]],"date-time":"2021-07-18T08:03:21Z","timestamp":1626595401000},"update-policy":"http:\/\/dx.doi.org\/10.1007\/springer_crossmark_policy","source":"Crossref","is-referenced-by-count":5,"title":["Adaptive watermark generation mechanism based on time series prediction for stream processing"],"prefix":"10.1007","volume":"15","author":[{"given":"Yang","family":"Song","sequence":"first","affiliation":[],"role":[{"role":"author","vocabulary":"crossref"}]},{"given":"Yunchun","family":"Li","sequence":"additional","affiliation":[],"role":[{"role":"author","vocabulary":"crossref"}]},{"given":"Hailong","family":"Yang","sequence":"additional","affiliation":[],"role":[{"role":"author","vocabulary":"crossref"}]},{"given":"Jun","family":"Xu","sequence":"additional","affiliation":[],"role":[{"role":"author","vocabulary":"crossref"}]},{"given":"Zerong","family":"Luan","sequence":"additional","affiliation":[],"role":[{"role":"author","vocabulary":"crossref"}]},{"given":"Wei","family":"Li","sequence":"additional","affiliation":[],"role":[{"role":"author","vocabulary":"crossref"}]}],"member":"297","published-online":{"date-parts":[[2021,7,18]]},"reference":[{"issue":"1","key":"206_CR1","doi-asserted-by":"publisher","first-page":"9","DOI":"10.14445\/22312803\/IJCTT-V19P103","volume":"19","author":"M H Iqbal","year":"2015","unstructured":"Iqbal M H, Soomro T R. Big data analysis: apache storm perspective. International Journal of Computer Trends and Technology, 2015, 19(1): 9\u201314","journal-title":"International Journal of Computer Trends and Technology"},{"key":"206_CR2","doi-asserted-by":"crossref","unstructured":"Armbrust M, Das T, Torres J, Yavuz B, Zaharia M. Structured streaming: a declarative api for real-time applications in apache spark. In: Proceedings of the 2018 International Conference on Management of Data. 2018, 601\u2013613","DOI":"10.1145\/3183713.3190664"},{"issue":"4","key":"206_CR3","first-page":"28","volume":"36","author":"P Carbone","year":"2015","unstructured":"Carbone P, Katsifodimos A, Sweden S, Tzoumas K. Apache flink: stream and batch processing in a single engine. Bulletin of the IEEE Computer Society Technical Committee on Data Engineering, 2015, 36(4): 28\u201337","journal-title":"Bulletin of the IEEE Computer Society Technical Committee on Data Engineering"},{"issue":"12","key":"206_CR4","doi-asserted-by":"publisher","first-page":"1792","DOI":"10.14778\/2824032.2824076","volume":"8","author":"T Akidau","year":"2015","unstructured":"Akidau T, Schmidt E, Whittle S, Bradshaw R Perry F. The dataflow model: a practical approach to balancing correctness, latency, and cost in massive-scale, unbounded, out-of-order data processing. Proceedings of the VLDB Endowment, 2015, 8(12): 1792\u20131803","journal-title":"Proceedings of the VLDB Endowment"},{"issue":"11","key":"206_CR5","doi-asserted-by":"publisher","first-page":"1033","DOI":"10.14778\/2536222.2536229","volume":"6","author":"T Akidau","year":"2013","unstructured":"Akidau T, Balikov A, Bekiro\u011flu K, Chernyak S, Haberman L. Mill-Wheel: fault-tolerant stream processing at internet scale. Proceedings of the VLDB Endowment, 2013, 6(11): 1033\u20131044","journal-title":"Proceedings of the VLDB Endowment"},{"key":"206_CR6","unstructured":"Awad A, Traub J, Sakr S. Adaptive watermarks: a concept drift-based approach for predicting event-time progress in data streams. In: Proceedings of the 22nd International Conference on Extending Database Technology."},{"issue":"3","key":"206_CR7","doi-asserted-by":"publisher","first-page":"295","DOI":"10.1162\/neco.1989.1.3.295","volume":"1","author":"H B Barlow","year":"1989","unstructured":"Barlow H B. Unsupervised learning. Neural Computation, 1989, 1(3): 295\u2013311","journal-title":"Neural Computation"},{"key":"206_CR8","doi-asserted-by":"crossref","unstructured":"Gers F A, Eck D, Schmidhuber J. Applying LSTM to time series predictable through time-window approaches. In: Proceedings of International Conference on Artificial Neural Networks. 2001, 669\u2013676","DOI":"10.1007\/3-540-44668-0_93"},{"key":"206_CR9","doi-asserted-by":"crossref","unstructured":"Chen T, Guestrin C. Xgboost: a scalable tree boosting system. In: Proceedings of the 22nd ACM Sigkdd International Conference on Knowledge Discovery and Data Mining. 2016, 785\u2013794","DOI":"10.1145\/2939672.2939785"},{"issue":"3","key":"206_CR10","doi-asserted-by":"publisher","first-page":"555","DOI":"10.1109\/TKDE.2003.1198390","volume":"15","author":"P A Tucker","year":"2003","unstructured":"Tucker P A, Maier D, Sheard T, Fegaras L. Exploiting punctuation semantics in continuous data streams. IEEE Transactions on Knowledge and Data Engineering, 2003, 15(3): 555\u2013568","journal-title":"IEEE Transactions on Knowledge and Data Engineering"},{"key":"206_CR11","doi-asserted-by":"crossref","unstructured":"Sun D, Hwang S. DSSP: stream split processing model for high correctness of out-of-order data processing. In: Proceedings of the 1st IEEE International Conference on Artificial Intelligence and Knowledge Engineering. 2018, 193\u2013197","DOI":"10.1109\/AIKE.2018.00044"},{"key":"206_CR12","doi-asserted-by":"crossref","unstructured":"Mutschler C, Philippsen M. Distributed low-latency out-of-order event processing for high data rate sensor streams. In: Proceedings of the 27th IEEE International Symposium on Parallel and Distributed Processing. 2013, 1133\u20131144","DOI":"10.1109\/IPDPS.2013.29"},{"issue":"3","key":"206_CR13","doi-asserted-by":"publisher","first-page":"545","DOI":"10.1145\/1016028.1016032","volume":"29","author":"S Babu","year":"2004","unstructured":"Babu S, Srivastava U, Widom J. Exploiting k-constraints to reduce memory overhead in continuous queries over data streams. ACM Transactions on Database Systems, 2004, 29(3): 545\u2013580","journal-title":"ACM Transactions on Database Systems"},{"key":"206_CR14","unstructured":"Kuralenok I E, Marshalkin N, Trofimov A, Novikov B. An optimistic approach to handle out-of-order events within analytical stream processing. In: Proceedings of CEUR Workshop Proceedings. 2018, 22\u201329"},{"issue":"5\u20136","key":"206_CR15","doi-asserted-by":"publisher","first-page":"311","DOI":"10.1002\/sam.10054","volume":"2","author":"A Dries","year":"2009","unstructured":"Dries A, R\u00f6ckert U. Adaptive concept drift detection. Statistical Analysis and Data Mining: The ASA Data Science Journal, 2009, 2(5\u20136): 311\u2013327","journal-title":"Statistical Analysis and Data Mining: The ASA Data Science Journal"},{"key":"206_CR16","doi-asserted-by":"crossref","unstructured":"Bifet A, Gavalda R. Learning from time-changing data with adaptive windowing. In: Proceedings of the 2007 SIAM International Conference on Data Mining. 2007, 443\u2013448","DOI":"10.1137\/1.9781611972771.42"},{"issue":"47","key":"206_CR17","first-page":"9478","volume":"3","author":"K M M Thein","year":"2014","unstructured":"Thein K M M. Apache kafka: next generation distributed messaging system. International Journal of Scientific Engineering and Technology Research, 2014, 3(47): 9478\u20139483","journal-title":"International Journal of Scientific Engineering and Technology Research"},{"key":"206_CR18","volume-title":"Time Series Analysis","author":"S Das","year":"1994","unstructured":"Das S. Time Series Analysis. Princeton University Press, Princeton, NJ, 1994"},{"key":"206_CR19","unstructured":"Gal Y, Ghahramani Z. A theoretically grounded application of dropout in recurrent neural networks. In: Proceedings of the 30th International Conference on Neural Information Processing Systems. 2016, 1019\u20131027"},{"key":"206_CR20","doi-asserted-by":"crossref","unstructured":"Sanjappa S, Ahmed M. Analysis of logs by using logstash. In: Proceedings of the 5th International Conference on Frontiers in Intelligent Computing: Theory and Applications. 2017, 579\u2013585","DOI":"10.1007\/978-981-10-3156-4_61"}],"container-title":["Frontiers of Computer Science"],"original-title":[],"language":"en","link":[{"URL":"https:\/\/link.springer.com\/content\/pdf\/10.1007\/s11704-020-0206-7.pdf","content-type":"application\/pdf","content-version":"vor","intended-application":"text-mining"},{"URL":"https:\/\/link.springer.com\/article\/10.1007\/s11704-020-0206-7\/fulltext.html","content-type":"text\/html","content-version":"vor","intended-application":"text-mining"},{"URL":"https:\/\/link.springer.com\/content\/pdf\/10.1007\/s11704-020-0206-7.pdf","content-type":"application\/pdf","content-version":"vor","intended-application":"similarity-checking"}],"deposited":{"date-parts":[[2023,1,27]],"date-time":"2023-01-27T12:23:14Z","timestamp":1674822194000},"score":1,"resource":{"primary":{"URL":"https:\/\/link.springer.com\/10.1007\/s11704-020-0206-7"}},"subtitle":[],"short-title":[],"issued":{"date-parts":[[2021,7,18]]},"references-count":20,"journal-issue":{"issue":"6","published-print":{"date-parts":[[2021,12]]}},"alternative-id":["206"],"URL":"https:\/\/doi.org\/10.1007\/s11704-020-0206-7","relation":{},"ISSN":["2095-2228","2095-2236"],"issn-type":[{"value":"2095-2228","type":"print"},{"value":"2095-2236","type":"electronic"}],"subject":[],"published":{"date-parts":[[2021,7,18]]},"assertion":[{"value":"20 May 2020","order":1,"name":"received","label":"Received","group":{"name":"ArticleHistory","label":"Article History"}},{"value":"15 September 2020","order":2,"name":"accepted","label":"Accepted","group":{"name":"ArticleHistory","label":"Article History"}},{"value":"18 July 2021","order":3,"name":"first_online","label":"First Online","group":{"name":"ArticleHistory","label":"Article History"}}],"article-number":"156213"}}