分上下兩個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])