flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Flavio Pompermaier <pomperma...@okkam.it>
Subject Re: Gelly forward
Date Wed, 08 Jul 2015 07:48:09 GMT
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>

> 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