如何在Spark中过滤RDD之后如何获取键的第一个值？

Question

我是新手。我已经使用GraphLoader制作了我的图形，并且我使用了mapVertices和以下代码来更改nodes属性：

case class nodes_property(label:Int,get_label:Boolean)

并且经过一些转换后，RDD中的每个节点都具有以下结构：

(1,nodes_property(12,true))
(2,nodes_property(9,false))
(3,nodes_property(12,true))
...

我使用graph.vertices.filter(x=>x._1==1)来过滤ID = 1的节点的值。我怎样才能选择值中的第一个元素？我的意思是我如何选择12（这是节点1的第一个值）？

Answer 1

您应该使用take（1）来取值，然后仅提取12个值，您应该执行以下操作：

val x=graph.vertices.filter(x=>x._1==1).values.take(1)
println(x(0).label)

这将只给出12。