每个窗口的每个键的 Spark 流查找比率

问题描述

所以我在 spark 中有一个 dstream,它为每个窗口生成键值对,例如:

(key1,10),(key2,20),(key3,30),(key4,40),

我喜欢执行一个映射,它会为每个窗口生成每个键值对的比率,例如:

(key1,0.1),0.2),0.3),0.4),

有没有什么办法可以在不对驱动程序做任何事情的情况下做到这一点?

解决方法

暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!

如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@)