2017-07-07 44 views

回答

0

你可以使用mapValues函數來解決這個問題。認爲productRDD具有結構:

[('someKey', (10, 20))] 

然後,爲了尋找新的RDD(resultRDD)持有價值的產品在productRDD我們使用:

resultRDD = productRDD.mapValues(lambda value: value[0] * (value[1])) 

的resultRDD將有以下數據:

[('someKey', 200)]