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）。