我有一个类对象列表的JavaRDD。我想将其展平为类对象的JaveRDD
JavaRDD 转到JavaRDD
在这篇文章中
Convert RDD List to RDD of individual element in spark
一种解决方案是
val newrdd = rdd.flatmap(line => line)
但是，line => line是scala（我认为）
我试过了
rdd.flatmap(line-> line)
它给与错误
“不存在类型变量为U的实例，因此List符合Iterator”
最佳答案
传递给function的flatMap应该返回java.util.Iterator<T>，而不是List<T>。这样做就足够了：
JavaRDD<SomeClass> newRdd = rdd.flatMap(List::iterator);
关于java - 将JavaRDD <List <SomeClass >>转换为JavaRDD <SomeClass>，我们在Stack Overflow上找到一个类似的问题：https://stackoverflow.com/questions/60266488/