第一问答网»论坛 › 中问网 › 问答 › 请问各位大神，sparkStreaming有没有updateState这样的 ...

请问各位大神，sparkStreaming有没有updateState这样的方法类似spark中的reduce（不通过key分组）？

11 |

1 | 2021-1-27 05:58:21 | 显示全部楼层 |阅读模式

现在有一组数据数据（K,V），我想用sparkStream实现更新累加的功能，同时对k和v都做累加
但是发现sparkStreaming中只有updateStateBykey(与spark中reduceByKey对应)，但是没有与spark中的reduce方法相对应的
请问各位大神有什么方便的解法，不用重新map数据。
分 -->

使用道具举报