Flink1.7学习笔记（二）时间戳和水印的使用

上文介绍了关于时间戳，时间，与水印的性质，接下来是关于如何在程序之中使用它们的用例。 ps：关于本文以及之后所用到的maven依赖与打包插件请参考 https://blog.csdn.net/hxw79321/article/details/86612814 就不在文章之中继续赘述。 首先要设置流环境的时间窗口类型（scala实现）web val env = StreamExecut

>>阅读原文<<