28 9 月 Flink, 大数据 Posted by 蓝染君 flink-25 窗口处理函数 思路一: 所有数据到一起,用hashmap存储, key=vc,value=count值 ... Continue reading
28 9 月 Flink, 大数据 Posted by 蓝染君 flink-22 迟到数据的处理 推迟水印推进 在水印产生时,设置一个乱序容忍度(延迟时间),推迟系统的时间的推进,保证窗口计算被延迟执行,为乱序的数据争取更多的时间进... Continue reading