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