Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.
Comment: Modified some lines about addInputPath/addOutputPath methods.

...

No Format
    // BSP job configuration 
    BSPJob bsp = new BSPJob(); 
    // Set the job name 
    bsp.setJobName("BSP test job"); 

    // Set ininput/output format classes
  path and formatter bsp.setInputFormat(MyInputFormat.class); 
    bsp.setInputPath(conf, new Path("input path")); setOutputFormat(MyOutputFormat.class); 

    // Like new MR API, set input/output targets with some concrete classes of both InputFormat
    // and OutputFormat. This method provides more flexible ways to specify targets.
    MyInputFormat.addInputPath(bsp, "/data/data1");
    bspMyOutputFormat.setOutputPathaddOutputPath(confbsp, new Path("output path"/result/data1")); 
;
    
    // or we could have another type of input/output targets as follows:
    // bspMyDBInputFormat.setInputFormat(MyInputFormat.class); addInputTable(bsp, "hbase://localhost/WebData");    
    // bspMyDBOutputFormat.setOutputFormat(MyOutputFormat.class); addOutputTable(bsp, "hbase://localhost/OutputTable");
     
    // Set the BSP code 
    bsp.setBSPCode(BSPProgram.class); 
    BSPJobClient.runJob(bsp);