incubator-giraph-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Avery Ching <>
Subject Re: Message processing
Date Thu, 08 Sep 2011 20:38:47 GMT
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?
>   -jake

View raw message