giraph-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Jake Mannix <>
Subject Message processing
Date Thu, 08 Sep 2011 19:59:03 GMT
Question about the message passing API:

  BaseVertex#sendMsg(I id, M msg)

sends messages.  And

  BaseVertex#compute(Iterator<M> msgIterator)

deals with them in a big iterator provided by the framework.  My question is
where the Iterator of messages is created?  If I wanted to say, subvert the
processing to avoid buffering them up into one big List, and instead handle
them as they come in, where would I look in the code to see where it's
buffered up?


View raw message