Преобразование JavaRDD <ArrayList<T>> для JavaRDD <T>

Question

Есть прямой способ преобразования JavaRDD<ArrayList<T>> в JavaRDD<T> с помощью Apache искру в Java API?

JavaPairRDD<NullWritable, ArrayList<Record>> baseRDD = sc.newAPIHadoopFile(args[2], InputFormat2.class, NullWritable.class,ArrayList.class, conf); 
JavaRDD<ArrayList<Record>> mapLines1 = baseRDD.values(); 

Я хочу, чтобы преобразовать JavaRDD<ArrayList<Record>> в JavaRDD<Record>.

Answer 1

Вы можете просто flatMap:

rdd.flatMap(new FlatMapFunction<ArrayList<Record>, Record>() { 
    @Override 
    public Iterable<Record> call(ArrayList<Record> records) { 
    return records; 
    } 
});