我想计算 PageRank 从csv文件的边缘格式化如下：
12,13,1.0
12,14,1.0
12,15,1.0
12,16,1.0
12,17,1.0
...我的代码：
var filename = "<filename>.csv"
val graph = Graph.fromCsvReader[Long,Double,Double](
env = env,
pathEdges = filename,
readVertices = false,
hasEdgeValues = true,
vertexValueInitializer = new MapFunction[Long, Double] {
def map(id: Long): Double = 0.0 } )
val ranks = new PageRank[Long](0.85, 20).run(graph)我从flink scala shell中得到以下错误：
error: type mismatch;
found : org.apache.flink.graph.scala.Graph[Long,_23,_24] where type _24 >: Double with _22, type _23 >: Double with _21
required: org.apache.flink.graph.Graph[Long,Double,Double]
val ranks = new PageRank[Long](0.85, 20).run(graph)
^我做错什么了？
（每个顶点的初始值为0.0，每个边的初始值为1.0是否正确？）
1条答案
按热度按时间uqjltbpv1#
问题是你给了斯卡拉
org.apache.flink.graph.scala.Graph至PageRank.run期望javaorg.apache.flink.graph.Graph.为了运行
GraphAlgorithm为了一个斯卡拉Graph对象，你必须调用runscala方法Graph与GraphAlgorithm.更新
在这种情况下
PageRank算法需要注意的是，算法需要一个类型为的示例Graph[K, java.lang.Double, java.lang.Double]. 自从java的Double类型与scala的不同Double类型（就类型检查而言），必须考虑到这一点。对于示例代码，这意味着