FLink的窗口机制与流处理Join的方案

FLink底层引擎是一个流式引擎，支持流处理和批处理，而window是streaming到batch的桥梁。由于流处理过程当中，数据是源源不断流进来的，须要对数据进行实时处理的话，能够经过来一个消息处理一个的方式，也能够经过把一段时间内的数据聚合以后，再一块儿处理的形式，此时须要定义一个窗口来收集过去那段时间内的数据再进行处理。缓存 Flink 提出了三种时间的概念，分别是event time（事

>>阅读原文<<