2016-11-24 3 views
2

У меня есть эти два ключ-значение РДА в искре:Разделить значения два РДА в свече (питон)

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)] 

ответ

3

Вы можете join и mapValues:

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

 Смежные вопросы

  • Нет связанных вопросов^_^