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); // 设置并行度
//
版权声明:本文为cobracanary原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。