分上下两个RDDS的值火花（蟒蛇）

Question

我有火花这两个键值RDDS：

rdd1 = [(u'Key1', 4), (u'Key2', 6), (u'Key3', 10)] 
rdd2 = [(u'Key1', 4), (u'Key2', 3), (u'Key3', 2)] 

我看火花函数来获取值的划分：（rdd3 =（ RDD1集/ RDD2））

在这种情况下：

rdd3 = [(u'Key1', 1), (u'Key2', 2), (u'Key3', 5)] 

Answer 1

您可以join和mapValues：

rdd1.join(rdd2).mapValues(lambda x: x[0]/x[1])