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