Apache Spark Convert Sammlung von RDD zu einzelnen RDD JAVA

Question

Ich habe folgende RDD in meinem Java-Code.

(1, List(1596, 1617, 1929, 2399, 2674)) 
(2, List(1702, 1785, 1933, 2054, 2583, 2913)) 
(3, List(1982, 2002, 2048, 2341, 2666)) 

Was ich versuche, ist eine weitere RDD erstellen. Der Inhalt soll wie folgt aussehen. (Nicht unbedingt in derselben Reihenfolge)

1596 
1617 
1929 
2399 
2674 
1702 
1785 
1933 
2054 
2583 
2913 
1982 
2002 
2048 
2341 
2666 

Ich bin nicht sicher, wie man RDD verwandeln Sie (JavaRDD<ArrayList<String>>) mit Sammlung von Objekten an einzelnen RDD (JavaRDD<String>) mit allen Objekten in ihm. Ich würde es sehr schätzen, wenn mich jemand auf irgendeine JAVA-Ressource hinweisen könnte. Dies wird in scala tun

Answer 1

Sie können das gleiche in scala tun, wie

val data = List((1, List(1596, 1617, 1929, 2399, 2674)), 
    (2, List(1702, 1785, 1933, 2054, 2583, 2913)), 
    (3, List(1982, 2002, 2048, 2341, 2666))) 

val rdd_data = sc.parallelize(data) 
val rdd_flattened = rdd_data.flatMap((index, value) => value)