...
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); |