我可以在Spark Streaming中使用mapWithState()像updateStateByKey()一样吗?



我正在使用函数mapWithState((而不是updateStateByKey((来加载初始状态并使用超时。但是我需要更新整个状态存储,无论是否使用了给定键的新值。

有没有办法这样做?

不,你不能这样做。如此处所述,由于mapWithState的性质,您不会/无法更新整个状态存储。

相关内容

  • 没有找到相关文章

最新更新