flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Vasiliki Kalavri <vasilikikala...@gmail.com>
Subject Re: Gelly forward
Date Wed, 08 Jul 2015 08:19:43 GMT
Is it the same message that you propagate or is it different for each
vertex / neighbor? If you have to store a <neighborID, msg> pair for each
neighbor, then you will quickly run out of memory. If it's the same message
you need to send, or you simply need to add the current vertex Id, then you
can probably get rid of the neighborID.

By "outbox" I believe you mean storing them in the vertex value, correct?
I don't think you will have to explicitly reset it, as in each superstep
vertices only receive messages sent in the previous superstep, i.e. "old"
messages don't get re-sent.
On Jul 8, 2015 9:48 AM, "Flavio Pompermaier" <pompermaier@okkam.it> wrote:

> The problem is that my nodes have to gather data coming from some path of
> interest along the graph (depending on the type of the node), otherwise
> they just have to forward the received message adding their id to the
> message path (more or less). It's like a postal tracking system.
> The problem is that I have to reset the "outbox" of each vertex once the
> messages have been sent..
> Do you think that it makes sense in this case to have an outbox of
> messages (destination, message) in each vertex and reset it in the
> postSuperstep() of the VertexUpdateFunction?
> On Wed, Jul 8, 2015 at 9:38 AM, Vasiliki Kalavri <
> vasilikikalavri@gmail.com> wrote:
>> Hi Flavio!
>> Are you talking about vertex-centric iterations in gelly?
>> If yes, you can send messages to a particular vertex with
>> "sendMessageTo(vertexId, msg)" and
>> to all neighbors with "sendMessageToAllNeighbors(msg)". These methods are
>> available inside the MessagingFunction.
>> Accessing received messages happens inside the VertexUpdateFunction.
>> So, the usual way of writing these programs is to:
>> (1) go through received messages in the VertexUpdateFunction and compute
>> the new vertex value based them
>> (2) compute and send messages in the MessagingFunction.
>> Would that work in you case?
>> Cheers,
>> Vasia.
>> On 8 July 2015 at 08:47, Flavio Pompermaier <pompermaier@okkam.it> wrote:
>>> Hi to all,
>>> is there a way in gelly to forward received messages (and modify their
>>> content before sending)?
>>> Best,
>>> Flavio

View raw message