rainbow2301

something wrong with random walk in node2vec_spark?

2

val edge2attr = graph.triplets.map { edgeTriplet => (s"${edgeTriplet.srcId}${edgeTriplet.dstId}", edgeTriplet.attr) }.repartition(200).cache (s"${prevNodeId}${currentNodeId}", (srcNodeId, pathBuffer)) }.join(edge2attr).map { case (edge, ((srcNodeId, pathBuffer), attr)) => in the code, join key is generated by s"${edgeTriplet.srcId}${edgeTriplet.dstId}",...