我可以在Spark Streaming中使用mapWithState（），如updateStateByKey（）吗？

Question

我正在使用函数mapWithState（）而不是updateStateByKey（）来加载初始状态并使用超时。但是我需要更新整个状态存储，无论给定密钥的新值是否已被消耗。

有没有办法做到这一点？

Answer 1

不，你不能这样做。如here所述，由于mapWithState的性质，您不会/不能更新整个国有店面。