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.
Avery
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?
-jake
