2015-12-03 43 views
-1

我試圖RDD [字符串]的所有值轉換爲浮動轉換的RDD [字符串]的所有元素漂浮在階

的RDD包含類似於此

15.994

數據

1.008

4.9594

一個等

RDD採用RDD [字符串]格式。

我需要計算所有這些值的總和,因此需要將它們轉換爲浮點數。

我發現在python這個問題的代碼,但我需要它在斯卡拉

Python代碼:

 val massData1 = [map(float,i) for i in massData] 

massData是RDD [字符串]

誰能告訴我我如何通過將RDD [字符串]中的所有值轉換爲浮點數來添加它們。

回答

0

假設你有一個包含字符串的strRDD,做如下改變:

val doubleRDD = strRDD.map(_.toFloat) 

然後把它們加起來:

val result = doubleRDD.reduce(_ + _)