是否可以向 Apache Giraph 中的前任发送消息?
Is it possible to send message to predecessor in Apache Giraph?
如题:在Apache Giraph中可以给前任发送消息吗?更重要的是推荐(我可以找到一些可能有用的应用程序)。
您可以向 Apache Giraph 中的任何随机节点发送消息,但您需要先找出它们的 ID。因此,要向前任发送消息,您首先需要找到他们的 ID,方法是将前任的消息发送给他们的所有继任者。我已经这样做了,这是一个非常糟糕的算法,我很难理解哪个(临时存储的)ID 属于哪个节点以及我应该向该节点发送什么。
当然,您可能有一些算法,其中绝对有必要能够与前一个节点进行通信(就像对我来说一样),但只跟随边缘肯定要容易得多。
关于改进 Giraph 和类似框架的研究正在进行,方法是允许一些节点在所有其他节点完成前一个超级步骤之前执行下一个超级步骤。这些算法使用有关边的信息来确定哪个节点仍可能收到消息或没有。如果您以相反的方式或随机发送消息,该算法将不再有效。但正如我所说,据我所知,他们仍在进行研究(我的一位同事做过其中一项),所以你现在不需要费心。
此外,据我所知,GraphX(在 spark 之上)只允许使用边发送消息,而不是相反,因此如果可能需要的话,您的算法将很难在那里重新实现。
如题:在Apache Giraph中可以给前任发送消息吗?更重要的是推荐(我可以找到一些可能有用的应用程序)。
您可以向 Apache Giraph 中的任何随机节点发送消息,但您需要先找出它们的 ID。因此,要向前任发送消息,您首先需要找到他们的 ID,方法是将前任的消息发送给他们的所有继任者。我已经这样做了,这是一个非常糟糕的算法,我很难理解哪个(临时存储的)ID 属于哪个节点以及我应该向该节点发送什么。
当然,您可能有一些算法,其中绝对有必要能够与前一个节点进行通信(就像对我来说一样),但只跟随边缘肯定要容易得多。
关于改进 Giraph 和类似框架的研究正在进行,方法是允许一些节点在所有其他节点完成前一个超级步骤之前执行下一个超级步骤。这些算法使用有关边的信息来确定哪个节点仍可能收到消息或没有。如果您以相反的方式或随机发送消息,该算法将不再有效。但正如我所说,据我所知,他们仍在进行研究(我的一位同事做过其中一项),所以你现在不需要费心。
此外,据我所知,GraphX(在 spark 之上)只允许使用边发送消息,而不是相反,因此如果可能需要的话,您的算法将很难在那里重新实现。