Not sure exactly what your asking but: 1) if you are asking do you need to implement synchronisation code - no that is built into the call to Pregel 2) if you are asking how is synchronisation implemented in GraphX - the superstep starts and ends with the beginning and end of a while loop in the Pregel implementation code (see http://spark.apache.org/docs/latest/graphx-programming-guide.html#pregel-api for pseudo-code or Pregel.scala in the source). This code will run in the driver and orchestrates the receipt of messages, vertex update program and send messages. All you need to do is supply the Merge message, vertex update and the send message functions to the Pregel method. Since GraphX objects are backed by RDDs and RDDs provided distributed processing you get synchronous distributed processing.
----- Robin East Spark GraphX in Action Michael Malak and Robin East Manning Publications Co. http://www.manning.com/books/spark-graphx-in-action -- View this message in context: http://apache-spark-user-list.1001560.n3.nabble.com/Where-to-implement-synchronization-is-GraphX-Pregel-API-tp25612p25622.html Sent from the Apache Spark User List mailing list archive at Nabble.com. --------------------------------------------------------------------- To unsubscribe, e-mail: user-unsubscr...@spark.apache.org For additional commands, e-mail: user-h...@spark.apache.org
