ich habe dies:Apache Spark - Scala - wie zu FlatMap (k, {v1, v2, v3, ...}) zu ((k, v1), (k, v2), (k, v3), ...)
val vector: RDD[(String, Array[String])] = [("a", {v1,v2,..}),("b", {u1,u2,..})]
wollen konvertieren:
RDD[(String, String)] = [("a",v1), ("a",v2), ..., ("b",u1), ("b",u2), ...]
eine Ahnung, wie das flatMap
mit zu tun. Diese
Dank, es funktionierte! – kambiz
@kambiz Sie sind willkommen. –
Was ist, wenn das zweite Array eine HashMap ist? Ich habe die gleiche Funktion versucht. Die Ergebnisse geben nur das erste Element der Karte zurück. – kambiz