网站介绍:文章浏览阅读1k次。1- 简介在开发过程中,如果遇到需要下发/广播配置、规则等低吞吐事件流到下游所有 task 时,就可以使用 Broadcast State。Broadcast State 是 Flink 1.5 引入的特性。下游的 task 接收这些配置、规则并保存为 BroadcastState, 将这些配置应用到另一个数据流的计算中 。场景例子:1)动态更新计算规则: 如事件流需要根据最新的规则进行计算,则可将**规则(数据量较少的)**作为广播状态广播到下游Task中。2)实时增加额外字段: 如事件流需要_flink processbroadcastelement
- 链接地址:https://blog.csdn.net/m0_49834705/article/details/119414130
- 链接标题:Flink高级特性之BroadcastState广播状态_flink processbroadcastelement-CSDN博客
- 所属网站:blog.csdn.net
- 被收藏次数:9097
- 网站标签:flink processbroadcastelement