保存PairedRDD爲文本文件

Question

users_grpd = pairs.groupByKey() 

users_grpd_flattened = meds_grpd.map(
    lambda keyValue: (keyValue[0], ' '.join(map(str, keyValue[1])))) 

users_grpd_flattened.saveAsTextFile('pairedrddresults.txt') 

輸出：

(u'3300975212', '120818 120519 120850 120521') 

(u'3200272220', '120036 105037') 

(u'131', '2024574 12024') 

我想知道是否有辦法救這個pairedrdd爲文本文件，其中的龍頭u和報價省略？

Answer 1

如果你需要一個特定的格式，可以在地圖上直接字符串：

users_grpd_flattened = (pairs.groupByKey(). 
    map(lambda (k, vals): "{0}, {1}".format(k, ' '.join(str(x) for x in vals)))) 

如果需要括號只是"({0}, {1})"替換格式字符串。