0
我正在使用函數mapWithState（）而不是updateStateByKey（）來加載初始狀態並使用超時。但是我需要更新整個狀態存儲，無論給定密鑰的新值是否已被消耗。我可以在Spark Streaming中使用mapWithState（），如updateStateByKey（）嗎？
有沒有辦法做到這一點？
A
回答
1
不，你不能這樣做。如here所述，由於mapWithState的性質，您不會/不能更新整個國有店面。
相關問題
- 1. 是否緩存了mapWithState/updateStateByKey？
- 2. Spark Streaming updateStateByKey與元組作爲值
- 3. Spark Streaming - updateStateByKey和緩存數據
- 4. 在Spark Streaming中使用mapWithState指定超時
- 5. Spark Streaming和Azure事件集線器mapWithState
- 6. Spark Streaming - 如何獲取updateStateByKey函數中的「密鑰」
- 7. Spark Streaming mapWithState似乎會定期重建完整狀態
- 8. Spark與多個KMeans與mapWithState
- 9. Spark Streaming Multiple Streaming Jobs
- 10. 使用Spark Streaming讀取fileStream
- 11. updateStateByKey，noClassDefFoundError
- 12. Spark Streaming - 可以針對數據流使用離線模型
- 13. 如果其他在Spark Streaming
- 14. 在spark-streaming中解析json
- 15. 在Spark Streaming中緩存DStream
- 16. 在Spark Streaming中的Kafka createDirectStream
- 17. Spark Streaming中的java.lang.LinkageError
- 18. Spark Streaming中的UnknownHostExceptionError
- 19. 使用Spark Streaming從Cassandra中讀取
- 20. Spark-Streaming Kafka Direct Streaming API＆Parallelism
- 21. 在spark應用程序中，mapWithState在哪裏執行？
- 22. Spark Streaming - 本地調用REST API vs構建功能以實現Spark Streaming
- 23. Tweepy Streaming API可以在Google App Engine上使用嗎？
- 24. Spark Streaming textFileStream COPYING
- 25. Spark Twitter Streaming
- 26. Spark Streaming HiveContext NullPointerException
- 27. Spark Streaming，kafka：java.lang.StackOverflowError
- 28. Spark Streaming Flume Integration
- 29. Spark Scala Streaming CSV
- 30. Spark Streaming MYsql