28 9 月 Flink, 大数据 Posted by 蓝染君 flink-27 状态管理 在flink中算子任务,可以分为无状态和有状态两种 无状态的算子任务只需要观察每个独立事件,根据当前输入的数据直接转换输出结果。之前讲... Continue reading
28 9 月 Flink, 大数据 Posted by 蓝染君 flink-25 窗口处理函数 思路一: 所有数据到一起,用hashmap存储, key=vc,value=count值 ... Continue reading
28 9 月 Flink, 大数据 Posted by 蓝染君 flink-22 迟到数据的处理 推迟水印推进 在水印产生时,设置一个乱序容忍度(延迟时间),推迟系统的时间的推进,保证窗口计算被延迟执行,为乱序的数据争取更多的时间进... Continue reading