-
-3 votesanswersviews
it.unimi.dsi.fastutil.objects.ObjectArraySet . <init>(Ljava / util / Collection;)V不存在
当我运行我的火花作业来创建我的DSE图时,我遇到了问题: My code : import com.datastax.bdp.graph.spark.graphframe._ object TestGraph extends App with SparkConnection { val graph = spark.dseGraph(cassandraConf.GRAPH_NAME) } ... -
4 votesanswersviews
将GraphFrames ShortestPath Map转换为PySpark中的DataFrame行
我试图找到最有效的方法从GraphFrames函数shortestPaths获取Map输出,并将每个顶点的距离映射平铺为新DataFrame中的各个行 . 通过将距离列拉入字典然后从那里转换为pandas数据帧然后转换回Spark数据帧,我已经能够非常笨拙地做到这一点,但我知道必须有更好的方法 . from graphframes import * v = sqlContext.createDa...