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?


Reply via email to