使用预凝胶寻找循环答案

【问题标题】：Finding cycle using pregel使用预凝胶寻找循环
【发布时间】：2018-09-12 14:07:43
【问题描述】：

任务是使用 Scala pregel 找到一定大小 k 的循环，其中 k 是用户输入。但是，当找到一个循环时，我不知道应该在 pregel 中发送哪些消息。到目前为止，我尝试的是使用一个字符串，其中包含它通过的顶点列表并将其放入顶点属性中。如果 srcAttr 已经包含 dstId，则检测到一个循环。但我不确定要获得循环总数后该怎么做。此外，任务还声明如果它包含其他更小的循环，则它不是一个循环。

【问题讨论】：

标签： scala graph cycle spark-graphx

【解决方案1】：

每个顶点向其邻居发送消息，其中包含 (1) 源顶点 ID，以及 (2) 消息要遍历的跳数（最初设置为 1）。

每个顶点在将 (2) 值加一后重新路由接收到的消息。

检查每条消息是否msg.src_vid == msg.dst_id，并查看跳数

【讨论】：