第二步
WatermarkStrategy,即:水位线生成策略,是接口,可通过下面 静态方法,返回接口对象
forBoundedOutOfOrderness
处理乱序数据
声明:
static <T> WatermarkStrategy<T> forBoundedOutOfOrderness(Duration maxOutOfOrderness)
注意: 方法前面有 泛型
forMonotonousTimestamps
处理时间戳是单调递增的数据,即:不会乱序
声明:
static <T> WatermarkStrategy<T> forMonotonousTimestamps()
创建类实现 WatermarkStrategy 接口
略