函数中的第一行是val lpaGraph = graph.mapVertices { case (vid,_) => vid},它将节点的ID作为其初始标签(属性)。我想做的事情是启动算法,不是使用等于节点id的标签,而是等于节点标签的当前状态。因为在执行LPA之前,我已经对图做了一些操作,并且一些节点有标签。首先,我用下面的代码在原始图形上做了一个mapvertices: case class nodes_properties(label: VertexId, isCoreNod
我一直在尝试将RDDs转换为DataFrames格式,然后再转换回来。首先,我有一个类型为(Int,Int)的RDD,名为dataPair。转换回RDD:它返回org.apache.spark.sql.Row类型的RDD (不是(整数,整数))。然后我想用.toDF把它转换回RDD,但是我得到了一个错误:
error: value toDF is not a member of