java - 将 JavaRDD<ArrayList<T>> 转换为 JavaRDD<T>

Question

有没有直接转换JavaRDD<ArrayList<T>>的方法至JavaRDD<T>使用 Apache-Spark 的 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;
  }
});