現在有一組資料資料(K,V),我想用sparkStream實作更新累加的功能,同時對k和v都做累加
但是發現sparkStreaming中只有updateStateBykey(與spark中reduceByKey對應),但是沒有與spark中的reduce方法相對應的
請問各位大神有什么方便的解法,不用重新map資料。
uj5u.com熱心網友回復:
提醒:sparkStreaming是開源的。轉載請註明出處,本文鏈接:https://www.uj5u.com/qita/56358.html
標籤:Spark
上一篇:docker push到dockerhub出錯:Error pushing to registry: Server error: 408 trying to··
下一篇:docker配置問題
