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
