flink广播流和广播状态

Question

关于广播流和广泛的卡塞特州，我有以下两个问题，谁能帮忙回答吗？谢谢!

1. KeyedBroadcastProcessFunction#Context有以下方法(GetBroadcastState)，我会问它为什么要使用映射状态描述符作为广义的转换状态？我认为广泛的转换状态应该使用类似于BroadcastStateDescriptor的东西，映射状态描述符用于MapState?

。

公共文摘 BroadcastState getBroadcastState(final MapStateDescriptor stateDescriptor)；

1. DataStream#broadcast方法定义如下：

javaStream.broadcast(broadcastStateDescriptors：

广播(broadcastStateDescriptors : MapStateDescriptor_，_*)：BroadcastStreamT ={ if (broadcastStateDescriptors == null) {抛出新NullPointerException(“状态描述符不能为空”)}

我会问broadcastStateDescriptors所用的论点是什么？我为何要在播放流媒体时，这么早便提供呢？我认为我可以创建描述符，并在需要时获得广播状态，在KeyedBroadcastProcessFunction#processBroadcastElement中，操作符接收广播元素并更新广播状态。

Answer 1

1. MapState是Flink支持广播的一种状态(也是唯一一种状态)。由于广播状态总是MapState，所以MapStateDescriptor是用来处理它的。

1. Flink需要知道如何序列化正在广播的数据；broadcastStateDescriptors被DataStream#broadcast用于此目的。