Flink 1.10 版本之前如何生成 Watermark
Posted @SmartSi
tags:
篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了Flink 1.10 版本之前如何生成 Watermark相关的知识,希望对你有一定的参考价值。
传送门:Flink 系统性学习笔记
Flink 1.10
我们说使用 Watermark,那我们是在基于事件时间处理数据,首先第一步就是设置时间特性:
final StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
env.setStreamTimeCharacteristic(TimeCharacteristic.
以上是关于Flink 1.10 版本之前如何生成 Watermark的主要内容,如果未能解决你的问题,请参考以下文章
Flink处理函数实战之一:深入了解ProcessFunction的状态(Flink-1.10)