Re: GraphX Pragel implementation

On Wed, Jul 30, 2014 at 04:55 PM, Arun Kumar wrote: > For my implementation to work the vprog function which is responsible for > handling in coming messages and the sendMsg function should be aware of > which super step they are in. > Is it possible to pass super step information in this methods

Re: GraphX Pragel implementation

Hello Ankur, For my implementation to work the vprog function which is responsible for handling in coming messages and the sendMsg function should be aware of which super step they are in. Is it possible to pass super step information in this methods? Can u through some light on how to approach t

Re: GraphX Pragel implementation

Hi Thanks for the quick response.I am new to scala and some help will be required Regards -Arun On Fri, Jul 25, 2014 at 10:37 AM, Ankur Dave wrote: > On Thu, Jul 24, 2014 at 9:52 AM, Arun Kumar wrote: > >> While using pregel API for Iterations how to figure out which super step >> the itera

Re: GraphX Pragel implementation

On Thu, Jul 24, 2014 at 9:52 AM, Arun Kumar wrote: > While using pregel API for Iterations how to figure out which super step > the iteration currently in. The Pregel API doesn't currently expose this, but it's very straightforward to modify Pregel.scala

Re: GraphX Pragel implementation

Hi While using pregel API for Iterations how to figure out which super step the iteration currently in. Regards Arun On Thu, Jul 17, 2014 at 4:24 PM, Arun Kumar wrote: > Hi > > > > I am trying to implement belief propagation algorithm in GraphX using the > pragel API. > > *def* pregel[A] > >

Re: GraphX Pragel implementation

Thanks On Fri, Jul 18, 2014 at 12:22 AM, Ankur Dave wrote: > If your sendMsg function needs to know the incoming messages as well as > the vertex value, you could define VD to be a tuple of the vertex value and > the last received message. The vprog function would then store the incoming > mess

Re: GraphX Pragel implementation

If your sendMsg function needs to know the incoming messages as well as the vertex value, you could define VD to be a tuple of the vertex value and the last received message. The vprog function would then store the incoming messages into the tuple, allowing sendMsg to access them. For example, if

GraphX Pragel implementation

Hi I am trying to implement belief propagation algorithm in GraphX using the pragel API. *def* pregel[A] (initialMsg*:* A, maxIter*:* Int = *Int*.*MaxValue*, activeDir*:* EdgeDirection = *EdgeDirection*.*Out*) (vprog*:* (VertexId, VD, A) *=>* *VD*, sendMsg*