Всем привет. Путаюсь с механизмом вотермарков во Flink. А я правильно понимаю, если использовать стратегию их генерирования таким образом в коде:
WatermarkStrategy.forBoundedOutOfOrderness(Duration.ofSecond(6))
То по каждому поступившему событию, будет высчитываться максимальный eventTime - 6 сек. - это и будет вотермарк.
Таким образом, из рисунка ниже первые три элемента попадают в w(0), а элементы 4, 5 и 6 в w(5).
При поступлении элемента 3: max = 11 --> 11-6 = w(5)
Элемент 4: 7 < 11, max = 11
Элемент 5: 9 < 11, max = 11
Элемент 4: 15 > 11, max = 15 --> 15-6 = w(9)