首先是张 Flink技术栈的图：
然后然后解释一下如何在高性能的情况下对数据进行保序操作处理：
如下图所示：
当数据从kafka进入Flink中，数据有序，再经过map处理后，根据本地的时间生成
Window，然后启动WaterMark机制，其中的时间叫做Ingestion Time，
京公网安备 11010802041100号