2016-05-15 75 views
0

我有Scala中两个阵列都用相同的数字映射在阶多个阵列

val v = myGraph.vertices.collect.map(_._1) 

其给出:

Array[org.apache.spark.graphx.VertexId] = Array(-7023794695707475841, -44591218498176864, 757355101589630892, 21619280952332745) 

和另一

val w = myGraph.vertices.collect.map(_._2._2) 

其给出:

Array[String] = Array(2, 3, 1, 2) 

,我想创建一个使用

val z = v.map("{id:" + _ + "," + "group:" + "1" + "}").mkString(",") 

这给出了一个字符串:

String = {id:-7023794695707475841,group:1},{id:-44591218498176864,group:1},{id:757355101589630892,group:1},{id:21619280952332745,group:1} 

但现在不是“1”的硬编码组,我想,而不是从数字地图w阵列给:

String = {id:-7023794695707475841,group:2},{id:-44591218498176864,group:3},{id:757355101589630892,group:1},{id:21619280952332745,group:2} 

我该如何做?

回答

1

在Scala集合中有一个名为zip的方法,它可以根据需要配对两个集合。

val v = Array(-37581, -44864, 757102, 21625) 
val w = Array(2, 3, 1, 2) 

val z = v.zip(w).map { 
    case (v, w) => "{id:" + v + "," + "group:" + w + "}" 
}.mkString(",") 

z变为:

{id:-37581,group:2},{id:-44864,group:3},{id:757102,group:1},{id:21625,group:2} 
+0

Slouc,感谢您的答复快和工作:) –