本文主要是介绍Flink学习笔记 --- WaterMark机制 and low WaterMark 保序机制，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！
首先是张 Flink技术栈的图：
然后然后解释一下如何在高性能的情况下对数据进行保序操作处理：
如下图所示：
当数据从kafka进入Flink中，数据有序，再经过map处理后，根据本地的时间生成
Window，然后启动WaterMark机制，其中的时间叫做Ingestion Time，
这篇关于Flink学习笔记 --- WaterMark机制 and low WaterMark 保序机制的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！
