java - Spark FlatMap - scala 到 java 代码

Question

我一直在练习 Spark 。我对scala不太熟悉，想尝试java代码。对于以下 map 和平面 map 的基本操作，我如何用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)。