巴中城市建设投资有限公司网站今天全国31个省疫情最新消息

github开源项目flink-note的笔记。本博客的实现代码都写在项目的flink-state/src/main/java/state/operator/BroadcastStateDemo.java文件中。
项目github地址： github

1. 广播状态是什么

网上关于flink广播变量、广播状态的讲解很杂。我翻了flink官网发现，实际上在1.15里面根本就没有广播变量这个东西了，flink使用了更为灵活的广播状态来实现了广播行为。

据我个人理解，广播状态实际上就是将一个流广播到所有的下游算子当中。当然这样说有些抽象，我首先给出一个小例子：

StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
env.setParallelism(3); // 设置并行度//