我可以在 Spark Streaming 中使用 mapWithState() 之类的 updateStateByKey() 吗？

Question

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

有办法吗？

Answer 1

不，你不能这样做。如here 所述，由于mapWithState 的性质，您将不会/不能更新整个状态存储。