scala - 传递数组的函数 foreach 键

Question

我有一个这样的数组：

val pairs: Array[(Int, ((VertexId, Seq[Int]), Int))] 

生成此输出：

(11,((11,ArraySeq(2, 5, 4, 5)),1))
(11,((12,ArraySeq(7, 7, 8, 2)),1))
(11,((13,ArraySeq(5, 9, 8, 7)),1))
(1,((1,ArraySeq(1, 2, 3, 4)),1))
(1,((4,ArraySeq(1, 5, 1, 1)),1))

我想为每个pairs._1. 这意味着例如那些具有相同 id (pair._1) 的人将一起构建一个 Graph。我正在考虑将 Graph Construction 的功能传递给每个 id。我怎样才能做到这一点 ？

Answer 1

您正在寻找处理每个组的groupBy函数。mapValues

pairs groupBy {_._1} mapValues { groupOfPairs => doSomething(groupOfPairs) }