flinkcdc添加水印

在Flink中，要为一个流添加水印，可以使用`assignTimestampsAndWatermarks`方法。`flinkcdc`是Flink的一个插件，用于从MySQL或PostgreSQL等关系型数据库中捕获变更数据。在使用`flinkcdc`时，可以在创建`SourceFunction`时调用`assignTimestampsAndWatermarks`方法来为流添加水印。

具体的操作步骤如下：
1. 在创建`SourceFunction`时，调用`assignTimestampsAndWatermarks`方法。
2. 在`assignTimestampsAndWatermarks`方法中，配置一个`WatermarkStrategy`来定义水印生成的逻辑。可以使用预定义的水印策略，比如`BoundedOutOfOrdernessWatermarks`，也可以自定义水印策略。
3. 在自定义的水印策略中，需要实现`WatermarkGenerator`接口，并重写`onEvent`和`onPeriodicEmit`方法来生成水印。
4. 在`onEvent`方法中，可以根据事件中的时间戳来更新水印。
5. 在`onPeriodicEmit`方法中，可以周期性地生成水印，比如每隔一定的时间或者处理一定数量的事件。

通过以上步骤，就可以为`flinkcdc`添加水印，以便在后续的窗口计算中处理乱序事件。

Watermark 是 Apache Flink 为了处理 EventTime 窗口计算提出的一种机制, 本质上是一种时间戳。 一般来讲Watermark经常和Window一起被用来处理乱序事件。
可以在处理前加一个fliter算子，将不符合规则的数据过滤出去。
Flink的开发者认为批处理是流处理的一种特殊情况。批处理是有限的流处理。Flink 使用一个引擎支持了DataSet API 和 DataStream API。