...
No Format |
---|
public static void main(String[] args) throws IOException, InterruptedException, ClassNotFoundException {
HamaConfiguration conf = new HamaConfiguration();
BSPJob job = new BSPJob(conf);
// set the BSP class which shall be executed
job.setBspClass(RealTime.class);
// help Hama to locale the jar to be distributed
job.setJarByClass(RealTime.class);
// give it a name
job.setJobName("Producer Consumer Test");
// use 4 tasks
job.setNumBspTask(4);
// output path must be defined
job.setOutputPath(new Path("/tmp/realtime-test"));
job.setOutputFormat(NullOutputFormat.class);
// submit the job to the localrunner and wait for its completion, while outputting logs
job.waitForCompletion(true);
}
|
...