hello all ..
i writte mapreduce in java . It works very well.
How i know a Job finished and sucess in java ?
JobConf conf = new JobConf(AverageJob.class);
conf.setJobName("AverageProductTime");
FileInputFormat.addInputPath(conf, new Path(inputDir));
FileOutputFormat.setOutputPath(conf, new Path(outputDir));
conf.setMapperClass(MapAverage.class);
conf.setReducerClass(RedAverage.class);
conf.setOutputKeyClass(Text.class);
conf.setOutputValueClass(IntWritable.class);
JobClient.runJob(conf);
if (JobClient.SUCCESS == 0)
{
... do someting ...
}
????
Thanks
|