spark结构化流媒体中的更新或广播变量?

dgiusagp  于 2021-05-29  发布在  Spark
关注(0)|答案(0)|浏览(214)

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

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题