微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦!

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

如何解决每个窗口的每个键的 Spark 流查找比率

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

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

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

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

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

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。