字符串火花階鍵值轉換

Question

我喜歡將字符串值轉換爲鍵值對

從這種格式：val1-12,val2-32,val3-43

到(val1,12),(val2,32),(val3,43)

Answer 1

你可以結合flatMap和map這樣

val string = Seq("val1-12,val2-32,val3-43") 
val rdd = sc.parallelize(string).flatMap(line => line.split(",")).map(row => row.split("-")).map(kv => (kv(0), kv(1)))