flink1.12.x Watermark:创建水位线的步骤2-创建 WatermarkStrategy 对象-WatermarkStrategy、forBoundedOutOfOrderness()、forMonotonousTimestamps()

第二步

WatermarkStrategy,即:水位线生成策略,是接口,可通过下面 静态方法,返回接口对象

forBoundedOutOfOrderness

处理乱序数据

声明:

static <T> WatermarkStrategy<T> forBoundedOutOfOrderness(Duration maxOutOfOrderness)

注意: 方法前面有 泛型

forMonotonousTimestamps

处理时间戳是单调递增的数据,即:不会乱序

声明:

static <T> WatermarkStrategy<T> forMonotonousTimestamps()

创建类实现 WatermarkStrategy 接口

略


原文出处:/show_1IX4Rx4WeI6h.html