spark flatmap - 斯卡拉java代码

Question

我一直在练习火花。我对scala不太熟悉，并且想要尝试java代码。对于地图和flatmap的以下基本操作，我如何用Java编写下面的代码

sc.parallelize(List(1,2,3)).flatMap(x=>List(x,x,x)).collect 
sc.parallelize(List(1,2,3)).map(x=>List(x,x,x)).collect 

Answer 1

这是基本相同：

sc.parallelize(Arrays.asList(1,2,3)).flatMap(x->Arrays.asList(x,x,x).iterator()).collect(); 
sc.parallelize(Arrays.asList(1,2,3)).map(x->Arrays.asList(x,x,x)).collect(); 

其中sc是JavaSparkContext（假设你使用Java 8和Spark 2.0.0）。