Dear Wiki user,

You have subscribed to a wiki page or wiki category on "Hama Wiki" for change 
notification.

The "Architecture" page has been changed by edwardyoon:
https://wiki.apache.org/hama/Architecture?action=diff&rev1=175&rev2=176

  
  == Communication and Synchronization Process ==
  
- Each BSPTask has a set of private outgoing and incoming queues. So, 
+ Each BSP task has a set of Outgoing Message Manager and Incoming Queue.
  
+ Outgoing Message Manager collects the message to be sent, serializes it, 
compresses it and puts it in a bundles. At barrier synchronization phase, each 
BSP task exchanges the bundles, deserializes it, decompresses it and puts it 
into the Incoming Queue.
-  1. Each task puts the message to be sent into message bundle asynchronously.
-  2. At sync() phase, sends them to destination Task. The received bundles 
from others goes into incoming (local) queue after unbundling.
  
  == System Diagram ==
  {{attachment:arch.png|alt Hama Cluster Startup Procedure}}

Reply via email to