Re: MessageCombiner

2014-05-11 Thread nishant gandhi
Let say I have 5 nodes which are sending message to 6th node. each 5 node sending one message to 6th node containing some value. I want to intercept all those 5 messages going towards 6th node. after that I want to find the maximum value contained among those 5 nodes. and send single message from c

Re: MessageCombiner

2014-05-11 Thread Maria Stylianou
Hi Nishant, Can you be more specific? Are you trying to combine all incoming messages of a vertex into one message? What do you mean combine? Add values? Or append to a list? The message can be a list so you can put all values together. Maria On Sunday, May 11, 2014, nishant gandhi wrote: > Hi

MessageCombiner

2014-05-11 Thread nishant gandhi
Hi, I am trying to write code that use Combiner. I want to combine all message into one for each vertex. That one message contains message value bigger than all the other message values. Please help. Nishant Gandhi M.Tech. CSE IIT Patna