| Table of Contents |
|---|
Overview
BSP Function
Inputs and Outputs
Communication Model
Synchronization
Setup and Cleanup
Combiners
...
— General Information —
In Apache Hama, you can implement your own BSP method by extending from org.apache.hama.bsp.BSP class. Apache Hama provides in this class a user-defined function bsp() that can be used to write your own BSP program.
...
In Apache Hama, the communication between tasks (or peers) is done within the barrier synchronization.
— Communication —
Within bsp() function, you can use the powerful communication functions for many purposes using BSPPeer. We tried to follow the standard library of BSP world as much as possible.
...
The generics in the BSPPeer are related to the Input and Output System.
— Synchronization —
When all processes have entered the barrier by sync() function, the Hama proceeds to the next superstep. In previous example case, the BSP job will be finished by one synchronization after sending a message “Hello from ...” to all peers. The sync() function is very flexible. For example, the sync() function can be also located in a for loop:
...