Flink 实现实时计数和按窗口计时功能程序设计

最近在开发程序的时候,有须要实时的计数处理,以及须要按照设计的窗口来补时长,在要求选用Flink处理后,程序大体架构设计入下: 其设计思路为:从kafk读取数据生成DataStream[Message]这样一个中间变量,而后将这个中间流分两个流,一个流用于实时计数,另外一个流,按照互动窗口,按照EventTime将消息划分到不一样的窗口,而后取出整个窗口的数据以及取出历史数据,造成完整窗口的数据,

>>阅读原文<<