spark scala中的字符串到键值转换

【问题标题】：string to key-value conversion in spark scalaspark scala中的字符串到键值转换
【发布时间】：2017-06-16 19:19:46
【问题描述】：

我喜欢将字符串值转换成键值对

从此格式：val1-12,val2-32,val3-43

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

【问题讨论】：

标签： scala apache-spark rdd

【解决方案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)))

【讨论】：