SerializePrinting

Serialize Printing of "Hello BSP"

Each BSP task of the HAMA cluster, will print the 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 the other peers.
• Each task prints the string "Hello BSP" only when its turn comes at intervals of 5 seconds.
  

BSP implementation of Serialize Printing of "Hello BSP"

• See the BSP programming model of HAMA if you didn't read yet.
  

    public void bsp(BSPPeerProtocol bspPeer) throws IOException,
        KeeperException, InterruptedException {

      int i = 0;
      for (String otherPeer : bspPeer.getAllPeerNames()) {
        String peerName = bspPeer.getPeerName();
        if (peerName.equals(otherPeer)) {
          writeLogToFile(peerName, i);
        }

        Thread.sleep(PRINT_INTERVAL);
        bspPeer.sync();
        i++;
      }
    }