Flink状态计算实例与状态数据恢复(checkpoint)

状态计算,简单的理解是本次计算依赖于以前的计算结果,好比,根据key计算求和值,如:html key  value 1001,3000-------------(1001,3000) 1002,500--------------(1002,500) 1001,400--------------(1001,3400) 其中计算第三条数据1001,400时须要累加到以前已经计算好的1001,30
相关文章
相关标签/搜索