我能够成功地导入pyspark和graphframes,但当我尝试时: from graphframes.lib import Pregel 我得到以下错误: ImportError: cannotimport name 'Pregel' from 'graphframes.lib' 这篇文章是我如何在没有graphframes.lib的情况下让graphframes工作的: https://github.comassembly-0.2.0-spark2.0.jar 我尝试重复上面的命令,没有环境
我是GraphX的新手,我不理解Pregel中的顶点程序和合并消息部分。难道他们不做同样的事吗?例如,在下面的Pregel代码中,顶点程序和合并消息部分有什么区别?graph.mapVertices((id, _) => if (id == sourceId) 0.0 else Double.PositiveInfinity)
val sssp = initialGraph.pregel
当我看着Pregel计算相同结果的方式时,我有点困惑(如下所示)。特别是当调用Pregel的apply方法时,maxIterations是缺省值Integer.MAX_VALUE (实际上它是‘永远运行’)。nothing changed (******) propagateEdgeCount(g2) g
val g = Pregel(myGraph.mapVert