Flink1.7學習筆記（二）時間戳和水印的使用

上文介紹了關於時間戳，時間，與水印的性質，接下來是關於如何在程序之中使用它們的用例。 ps：關於本文以及之後所用到的maven依賴與打包插件請參考 https://blog.csdn.net/hxw79321/article/details/86612814 就不在文章之中繼續贅述。 首先要設置流環境的時間窗口類型（scala實現）web val env = StreamExecut

>>阅读原文<<