Examples of org.apache.hama.bsp.BSPJobClient.submitJob()

org.apache.hama.bsp.BSPJobClient.submitJob()
Submit a job to the BSP system. This returns a handle to the {@link RunningJob} which can be used to track the running-job. @param job the job configuration. @return a handle to the {@link RunningJob} which can be used to track therunning-job. @throws FileNotFoundException @throws IOException

    bsp.setNumBspTask(cluster.getMaxTasks());


    LOG.info("Client conf: "
        + clientConf.get("hadoop.rpc.socket.factory.class.default"));


    RunningJob rJob = jobClient.submitJob(bsp);
    rJob.waitForCompletion();
    LOG.info("finished");
  }


}

View Full Code Here

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.