字符串火花阶键值转换

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