我想在ArangoDB中检索pregel的结果。下面是一个在arangosh中的简单例子。var pregel = require("@arangodb/pregel");var execution = pregel.start("sssp", "CountryGraph", params);
在文档中，它将pregel的
浏览 0提问于2018-01-10得票数 0
回答已采纳
1回答
我想在遍历图时添加一个计数器，for v,e,p in 1..1 any x._id graph'mygraph'我想在遍历集合之后添加一个计数器，我想在遍历加1之后遍历图形计数器。for x in mycollectionreturn v我对这个集合的长度不感兴趣，我只想在每个集合之后遍历图，计数器加1我写了两个未完成的js文件，实际上，我试图找出我的图中的弱连
浏览 3提问于2017-12-19得票数 1
我正在尝试用Pyspark和图形框架实现来自Rocha & Thatte ()和pregel包装器的算法。在这里，我被用于消息聚合的正确语法卡住了。()) \ .aggMsgs(f.collect_list(Pregel.msg())) \ .setMaxIter(5) \
.withVertexColumn("is_cycle", lit(""),
浏览 0提问于2019-11-16得票数 3
回答已采纳
Google描述了一个用于海量图的分布式处理的新框架。
实际上，我正在使用python和多处理模块编写一个伪分布式程序，因此想知道是否有人也尝试过实现它。因为关于这个框架的公开信息极其稀缺。(上面的链接和Google Research的一篇博客文章)
浏览 0提问于2010-06-07得票数 21
我在这里给出了在pregel逻辑中实现的SSSP算法的正式代码，您可以看到只有接收到消息的顶点才会在下一次迭代中执行他们的程序，但对于我的情况，我希望pregel函数迭代地运行，即每个超步顶点执行它们的程序这个例子中的推理看起来不像Pregel的纸逻辑。关于如何实现Pregel的真实逻辑，请有什么想法吗？graph.mapVertices((id, _) =>val sssp = initialGra
浏览 1提问于2018-11-29得票数 6
回答已采纳
Pregel令人印象深刻。请告诉我关于pregel中“分区”的任何线索，即如何智能地对图进行分区，以最大限度地减少进程之间的滞后。
浏览 3提问于2012-03-06得票数 0
1回答
我试图计算星星图中节点值的总和。简而言之，图是一棵树，顶部节点(根)应该是所有子节点及其子节点之和。我的图实际上是一棵树，看起来像这样，的期望值应该是1850 +---------------> | VertexID 14 +---+--+ +----+
+----------
浏览 3提问于2017-01-03得票数 7
回答已采纳
我能够成功地导入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 我尝试重复上面的命令，没有环境
浏览 30提问于2019-05-30得票数 1
回答已采纳
我试图在我的数据集上运行连通分量算法，但在有向图上。我不希望连通的分量在两个边的方向上都是横向的。import org.apache.log4j.{Level, LogManager}import org.apache.spark.graphx.Edgeimport org.graphframes._
val sparkConf = new
浏览 37提问于2017-02-28得票数 2
我需要使用Graphx Pregel API在无向图上运行计算。如果我设置activeDirection = EdgeDirection.Either，它会忽略图形的方向性吗？
浏览 0提问于2016-05-25得票数 1
1回答
我已经开始学习一些Scala\GraphX来与Pregel一起使用它，我在这里找到了一些简单的代码：，并想尝试它。._1)) (initialMsg: A,SparkConf().setAppName("Simple Application")
val minGraph = graph.pregel<
浏览 0提问于2017-01-16得票数 1
回答已采纳
1回答
我正在使用GraphX和Pregel的Java。我正在尝试实现一个MaxValue算法(给定一个加权图，输出是最大权重)。$.MODULE$.apply(Integer.class), ); Integer.MIN_V
浏览 2提问于2016-08-28得票数 3
我是GraphX的新手，我不理解Pregel中的顶点程序和合并消息部分。难道他们不做同样的事吗？例如，在下面的Pregel代码中，顶点程序和合并消息部分有什么区别？graph.mapVertices((id, _) => if (id == sourceId) 0.0 else Double.PositiveInfinity)
val sssp = initialGraph.pregel
浏览 3提问于2016-04-29得票数 0
回答已采纳
1回答
使用pregel查找循环
、、、
任务是使用Scala pregel找到特定大小k的循环，其中k是用户输入。然而，当发现一个循环时，我不知道在pregel中应该发送什么消息。
浏览 9提问于2018-09-12得票数 1
vertexRDD是不可变的，但是如何正确地更新spark.graphx.pregel中的vectexRDD呢？你能给我什么建议吗？
浏览 3提问于2020-04-23得票数 0
在并发Erlang的Pregel实现中，supersteps的全部目的是什么？
浏览 1提问于2011-09-20得票数 3
回答已采纳
我想知道有向图中来自给定顶点的可达顶点的数量(见下图)，例如对于id=0L，因为它连接到1L和2L，1L连接到3L，2L连接到4L，因此输出应该是4。下面是图形关系数据：0 0 1 10.02 1 2 2.04 2 1 3.06 2 4 2.08 4 0 7.0我能够设置图形，但我不知道如何使用graph.edges.filter来获得输出
val vertexRDD: RDD[(Long, (Double))] = sc.parall
浏览 0提问于2018-04-27得票数 1
1回答
传入参数的匿名方法
、、、、
我已经在Pregel中创建了一个方法，它具有以下签名：AIterator<Tuple2<Object,A>>>,
Function2<A,A,A>, ClassTag<VD>, ClassTag<ED>, ClassTag<A>) in the type Pregel
浏览 3提问于2017-10-02得票数 0
在Spark GraphX中，ShortestPaths不接受RDD作为输入，而接受Seqval paths = ShortestPaths.run(graph,graph.vertices)
浏览 3提问于2017-04-05得票数 1
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
