我在星火GraphX (Scala)中有一个有向图G。我想找出从已知的顶点v1开始到另一个顶点v2的交叉边的数目。换句话说，我需要从顶点v1到以边数计算的顶点v2的最短路径(不使用边的权重)。
浏览 5提问于2016-05-10得票数 4
回答已采纳
下面的代码运行良好，它打印出两个顶点之间的最短路径长度。但是如何打印出两个顶点之间的实际路径或细节边(而不仅仅是长度)？a,b) => math.min(a,b)(1,2.0)(3,1.0)(2
浏览 100提问于2021-11-11得票数 0
回答已采纳
使用spark graphx pregel api，可以很容易地计算大型图中的单源最短路径，例如数百万个顶点和数千万条边，并且运行时间可以接受，例如几个小时。但是，在可接受的运行时间内，是否有可能在大图中运行所有对的最短路径？
浏览 0提问于2016-05-12得票数 7
考虑到这个图表：
例如，从VertexId 5返回5-3-7-8-10。谢谢!
浏览 0提问于2018-12-04得票数 1
回答已采纳
我正在尝试实现一种加权最短路径算法，该算法来自Michael和Robin的Spark GraphX in Action书。讨论的部分是清单6.4“执行使用面包屑的最短路径算法”(第6章 )。我可以使用本机GraphX库执行未加权最短路径计算，并且我对图的构造很有信心。$.dijkstra$1(GraphX.scala:51)
at GraphX$.main
浏览 2提问于2016-10-24得票数 2
回答已采纳
我是spark GraphX的新手，正在尝试分布式地计算特定节点(例如ID =1的节点)与spark graphx中的邻居之间的交集。我已经用路径加载了边缘列表(sc，“GraphLoader.edgeListFile”)。然后，我使用collectNeighborIds找到节点ID =1的邻居id，并对其执行映射函数，以找到每个邻居并计算与选定节点( ID =1的节点)邻居的交集。下面是代码。但是我不能把它们打印出来，看看里面是什么。请帮我解决这个计算交集和打印结果的
浏览 56提问于2019-08-20得票数 2
回答已采纳
我想要做的是将我创建的图传播给所有的顶点，然后每个顶点都可以在这个图上进行自己的计算，以计算相对于自身作为源顶点的最短路径？
浏览 0提问于2017-03-06得票数 1
在Spark GraphX中，ShortestPaths不接受RDD作为输入，而接受Seqval paths = ShortestPaths.run(graph,graph.vertices是否有使用map或aggregateMessages解决此问题的方法？或者我必须自己重写路径查找代码？
浏览 3提问于2017-04-05得票数 1
我正在寻找Titan和Spark-GraphX之间的区别，以及哪一个最好使用。我用谷歌搜索了一下，但没有找到关于这方面的文章
有没有人能对此指点一下？？
浏览 0提问于2016-02-02得票数 4
我想在图中找到一条从源到目标的最短路径。在实现过程中，我使用了Map var predecessors : Map[VertexId, ListBuffer[VertexId]] = Map() 但当我尝试更新它时： predecessorspredecessors.updated(t, predecessors.getOrElse(t, ListBuffer.empty[VertexId]) :+ v) 我弄错了 Expression of type Map[graphx.VertexId, ListBuffer[_
浏览 24提问于2020-11-27得票数 0
1回答
如何在图形中并行素数算法
、、、、
因此，我试图为Prims算法编写一个并行算法，但我不太清楚如何使用Spark来实现它。我很难找到资源，但是在图中实现最短路径算法的例子不多。我认为我需要使用除法和征服，并将图分割成子图，然后合并它们的MST。import org.apache.spark.SparkContextimport org.apache.spark.SparkConfimport
浏览 3提问于2016-04-25得票数 3
回答已采纳
2回答
为了在最终的模型迭代中找到“平均最短路径”，我实现了Dijkstra算法，该算法计算从所有节点到所有节点的最短路径。更具体地说，该算法计算从网络3,000个节点中的每一个到所有其他3,000个节点的最短路径(如果存在路径)，大约9,000,000个路径长度，然后求出平均路径长度。当我尝试这样做时，我会耗尽内存。我能够得到大约500个节点的平均路径长度，在不到12小时的时间内计算出大约250,000个路径</e
浏览 17提问于2017-07-19得票数 0
回答已采纳
我知道如何使用DijkstraShortestPath找到最短路径，但我想知道如何找到两个节点之间的所有最短路径，并将它们打印出来。例如，在顶点A和C之间有两条最短路径都是3跳，这样打印出A，B，D，C和A，E，F，C谢谢！
浏览 7提问于2012-11-20得票数 1
回答已采纳
1回答
Neo4j作为火花放电的数据源
、、、、
我有一个要求，我必须从Neo4j中提取数据，并从这些数据中创建Spark。我在我的项目中使用Python。连接器具有相同的用途，但它是用Scala编写的。所以我现在可以想出解决办法-
我想知道
浏览 7提问于2018-01-09得票数 2
0回答
我需要在Scala中使用Apache Spark Graphx实现HDRF:幂律图算法的基于流的分区，我有以下数据集- 1 3 2 4 3 4如何实现该算法？然而，现在我已经能够加载这个图，但是我不知道如何在hdrf中进行分区。我尝试在graphx的partitionStrategy类中实现该算法，但结果很差import org.apache.s
浏览 9提问于2017-11-30得票数 1
2回答
IntelliJ:标量坏符号引用
、、、、
scalaVersion := "2.10.4"
libraryDependencies+= "org.apache.spark" % "spark-hive_2.10" % "1.3.1"
libraryDependencies += "
浏览 4提问于2015-09-16得票数 1
我正在检查将星火GraphX图输出到土卫六图形数据库的可行性。***Used below code to construct graph in Spark GraphX and writing graph to a json file :***val graph = Graph(users, relationships)在运行上
浏览 2提问于2016-02-10得票数 1
这里是我的sbt，用于在Intellij上使用scalalibraryDependencies += "org.apache.spark" %
浏览 2提问于2017-10-14得票数 0
回答已采纳
我在我的代码中有一个问题，当我映射一个在全局图形变量上调用最短路径的函数时，我收到一个空指针异常运行时错误。
浏览 0提问于2016-05-12得票数 0
我试着理解如何使用Spark，但总是有一些问题，所以也许有人可以建议我读什么等等。我试着阅读火花文档和学习火花-O‘’Reilly媒体书，但找不到任何解释，我们需要多少内存来处理不同大小的网络等等。在我的测试中，我使用了几个示例数据集。我在Spark中的一个主节点(~16 on )上运行它们：:load /home/ubuntu/spark-1.2.1/bin/script.scala
我还没有使用HD
浏览 1提问于2015-05-04得票数 0
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储
腾讯云开发者
