...
Each BSP task of the HAMA cluster, will print the LOG string "Hello BSP" in serial order. This example will help you to understand the concepts of the BSP computing model.
- Each task gets its own hostname (hostname:port pair) and a sorted list containing the hostnames of all hostname in HAMA cluster.the other peers
- Each task print prints the LOG string "Hello BSP" only when their its turn comes .
See below the diagram bellow if you don't understand:
BSP implementation of Serialize Printing of "Hello BSP"
...
| No Format |
|---|
public class SerializePrinting {
public static class HelloBSP extends BSP {
public static final Log LOG = LogFactory.getLog(HelloBSP.class);
private Configuration conf;
@Override
public void bsp(BSPPeer bspPeer) throws IOException, KeeperException,
InterruptedException {
int num = Integer.parseInt(conf.get("bsp.peers.num"));
int i = 0;
for(Map.Entry<String, String> e : bspPeer.getAllPeers().entrySet()) {
if(bspPeer.getHostName().equals(e.getValue())) {
LOG.info("Hello BSP from " + i + " of " + num + ": "
+ bspPeer.getHostName());
}
Thread.sleep(200);
bspPeer.sync();
i++;
}
}
@Override
public Configuration getConf() {
return conf;
}
@Override
public void setConf(Configuration conf) {
this.conf = conf;
}
}
public static void main(String[] args) throws InterruptedException,
IOException {
// BSP job configuration
HamaConfiguration conf = new HamaConfiguration();
// Execute locally
// conf.set("bsp.master.address", "local");
BSPJob bsp = new BSPJob(conf, SerializePrinting.class);
// Set the job name
bsp.setJobName("serialize printing");
bsp.setBspClass(HelloBSP.class);
BSPJobClient.runJob(bsp);
}
}
|