String Schlüssel-Wert-Umwandlung in Funken scala

Question

Ich mag die String-Werte Schlüsselwertepaare

von diesem Format konvertieren: val1-12,val2-32,val3-43

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

Answer 1

Sie flatMap und map wie folgt kombinieren

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