所以我在spark中有一个dstream,它为每个窗口生成键值对,比如:
(key1, 10),(key2, 20),(key3, 30),(key4, 40),
(key1, 10),
(key2, 20),
(key3, 30),
(key4, 40),
我喜欢执行一个Map,为每个窗口生成每个键值对的比率,例如:
(key1, 0.1),(key2, 0.2),(key3, 0.3),(key4, 0.4),
(key1, 0.1),
(key2, 0.2),
(key3, 0.3),
(key4, 0.4),
有没有什么方法可以不用对司机做任何事?
目前还没有任何答案,快来回答吧!
暂无答案!
目前还没有任何答案,快来回答吧!