flink实战--广播状态的使用

mac2024-05-26  59

扫一扫加入大数据公众号和技术交流群,了解更多大数据技术,还有免费资料等你哦

BroadcastState简介

             Broadcast State 是 Flink 1.5 引入的新特性。在开发过程中,如果遇到需要下发/广播配置、规则等低吞吐事件流到下游所有 task 时,就可以使用 Broadcast State 特性。下游的 task 接收这些配置、规则并保存为 BroadcastState, 将这些配置应用到另一个数据流的计算中 。Broadcast State 区别于其他 operator state 的地方有:

Broadcast State 类似 Map 结构,可以 put get putAll remove 等 必须有一条广播流和一条非广播流 符合条件的 operator 可以有多个不同名字的 BroadcastState(疑惑:普通的 operator 也可以有多个不同名字的 state 吧,只是不是 BroadcastState。这么想也说得通了)

BroadcastState运行场景

动态规则:动态规则是一条事件流&#
最新回复(0)