Page History

public class BSPEaxmple {

  //class BSPMyBSP jobextends configurationBSP {

    BSPJobpublic bsp = new BSPJob(); MyBSP(Configuration conf) throws IOException {
    // Set the job name 
 super(conf);
       bsp.setJobName("BSP test job"); 
// TODO Auto-generated constructor stub
    //}

 Set input/output format classes@Override
    public void bsp.setInputFormat(MyInputFormat.class); (BSPPeer bspPeer) throws IOException, KeeperException,
    bsp.setOutputFormat(MyOutputFormat.class); 

   InterruptedException //{
 Like new MR API, set input//output targetsA withcommunication someand concretesynchronization classesphase of a bothBSP InputFormatsuperstep
    //  
 and OutputFormat. This method provides more// flexibleSend waysdata to specifyneighbor targets.node
    MyInputFormat  bspPeer.addInputPathsend(bsphostname, "/data/data1"msg);

     MyOutputFormat.addOutputPath(bsp, "/result/data1");/ Superstep synchronization
      bspPeer.sync();

      // or we could have another type of input/output targets as follows:
    // MyDBInputFormat.addInputTable(bsp, "hbase://localhost/WebData");    
    // MyDBOutputFormat.addOutputTable(bsp, "hbase://localhost/OutputTable");
      Receive current messages
      bspPeer.getCurrentMessage();
    }
    
  }
  
  // BSP job configuration 
  public void main(String[] args) throws Exception {
    BSPJob bsp = new BSPJob(new HamaConfiguration());
    // Set the BSP code job name
    bsp.setJobName("My BSP Job");
    bsp.setBSPCodesetBspClass(BSPProgramMyBSP.class);

    // Submit job
    bsp.submit();
  }

}