If I'm understanding your question correctly, the iterator is created in GraphMapper, just before compute() is called. Messages are tranferred to the vertices prior to the compute portion superstep.


On 9/8/11 12:59 PM, Jake Mannix wrote:
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