28 9 月 Flink, 大数据 Posted by 蓝染君 flink-30 状态后端 在flink中状态的存储、访问以及维护,都是由一个可拔插的组件决定:状态后端(state backend) 状态后端主要复制管理本地状... Continue reading
28 9 月 Flink, 大数据 Posted by 蓝染君 flink-29 算子状态 算子状态就是一个算子并行实例上定义的状态,作用范围被限定为当前算子任务 算子状态的实际应用场景不如K... Continue reading
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