📌  相关文章
📜  使用关联和交换归约函数合并每个键的值. - Python 代码示例

📅  最后修改于: 2022-03-11 14:46:42.709000             🧑  作者: Mango

代码示例1
from operator import add
rdd = sc.parallelize([("a", 1), ("b", 1), ("a", 1)])
sorted(rdd.reduceByKey(add).collect())
# [('a', 2), ('b', 1)]