我面临一个问题，我必须更新广播Map后，一定的时间间隔。当我使用spark流时，我可以通过在广播变量周围创建一个 Package 器来实现这一点，但是这个解决方案在spark结构化流中不起作用。有谁知道怎么解决这个问题。