如何在Spark中将两个数组并入数组中？

Question

假设我们有两个数组Array1（1,2,3）和Array2（4,5,6）。 我想将它们结合到一个新的Array3（（1,4），（2,5），（3,6）） 当我在Spark中尝试时，它变成了。

代码

val data1 = Array(1, 2, 3, 4, 5) 
val data2 = Array(2, 3, 4, 5, 6) 
val distData1 = sc.parallelize(data1) 
val distData2 = sc.parallelize(data2) 

val distData3 = distData1 ++ distData2 
distData3.foreach(println) 

输出

1 
2 
3 
4 
5 
6 

我怎样才能正确地结合起来呢？

//更新*

在我的程序（与示例不同）。我想label.zip（功能）。我的功能是功能：Array [String]和我的标签也是Array [String]。为什么它不起作用？

<console>:98: error: type mismatch; 
found : org.apache.spark.rdd.RDD[Array[String]] 
required: scala.collection.GenIterable[?] 

Answer 1

您可以data1.zip(data2)，但如果发行版不同，它将不起作用。