2015-01-15 26 views

回答

1

您可以將消息發送到Apache Giraph中的任意隨機節點,但您需要首先找到它們的ID。因此,要將消息發送給前任,首先需要通過將消息從前輩發送給所有後繼者來查找他們的ID。我已經完成了這個工作,這是一個非常麻煩的算法,我很難理解哪個(臨時存儲的)ID屬於哪個節點,我應該發送給這個節點。

當然你可能有一些算法,它能夠與前一個節點進行通信是絕對必要的(就像它對我來說那樣),但只要沿着邊緣就可以更容易。

目前正在研究改進Giraph和類似的框架,通過允許一些節點在每個其他節點完成前一個節點之前執行下一個超級節點。這些算法使用有關邊緣的信息來確定哪個節點仍可能收到消息。如果您以其他方式或隨機發送消息,則該算法不再有效。但正如我所說,據我所知,他們仍在進行研究(我的一位同事做了其中的一個),所以你現在不需要爲此而煩惱。另外,AFAIK,GraphX(在spark之上)只允許使用邊而不是其他方式發送消息,所以如果這可能是需求,那麼你的算法很難在那裏重新實現。

+0

感謝您的回答! – iku

相關問題