这里分类和汇总了欣宸的全部原创(含配套源码):https://github.com/zq2599/blog_demos
学习Flink的ProcessFunction过程中,官方文档中涉及状态处理的时候,不止一次提到只适用于keyed stream的元素,如下图红框所示:
之前写过一些flink应用,keyed stream常用但不是必须用的,所以产生了疑问:
先去回顾Flink"状态"的知识点:
为了学习ProcessFunction就去看官方demo,地址是:https://ci.apache.org/projects/flink/flink-docs-release-1.10/dev/stream/operators/process_function.html ,简单说说这个demo的功能:
以上就是官方demo的功能,本来是想通过demo来加深认识,结果看完不但没有明白,反而更晕了,下图是我对demo代码的疑惑:
从上图可见我的疑惑,这里再复述一下:
最后,根据上面的分析过程绘制了一幅简陋的流程图,希望能帮助您加快理解: