第一步：生成水位线

通过算子（如：map、flatMap、keyBy 算子）的 .assignTimestampsAndWatermarks() 方法指定 时间戳 和 水位线

方法声明

public SingleOutputStreamOperator<T> assignTimestampsAndWatermarks(
  WatermarkStrategy<T> watermarkStrategy
)

形参：

• WatermarkStrategy<T> watermarkStrategy：水位线生成策略。WatermarkStrategy 是接口，一般调用现成的方法即可

调用方式

.map()
.assignTimestampsAndWatermarks()
.keyBy()
.window()
.聚合函数()

原文出处：/show_1IX4Rx4uoGGo.html