You are viewing a plain text version of this content. The canonical link for it is here.
Posted to common-dev@hadoop.apache.org by 于凤东 <fe...@gmail.com> on 2009/11/04 11:43:52 UTC
Who can give me an example to tell me how to use JobControl? Thanks
my Code sinpper: but it doesn't work;
public class TestMain {
/**
* @param args
*/
public static void main(String[] args) throws Exception{
JobControl jc = new JobControl("JC");//
JobConf conf = new JobConf(TestMain.class);
conf.setJobName("Tester1");
conf.setInputFormat(TextInputFormat.class);
conf.setOutputFormat(TextOutputFormat.class);
TextInputFormat.setInputPaths(conf, new Path("test"));
TextOutputFormat.setOutputPath(conf, new Path("out"));
conf.setOutputKeyClass(Text.class);
conf.setOutputValueClass(NullWritable.class);
conf.setMapperClass(Mapper1.class);//
conf.setNumReduceTasks(0);//
JobConf conf2 = new JobConf(AnotherMain.class);
conf2.setJobName("Tester2");
conf2.setInputFormat(TextInputFormat.class);
conf2.setOutputFormat(TextOutputFormat.class);
TextInputFormat.setInputPaths(conf2, new Path("out"));
TextOutputFormat.setOutputPath(conf2, new Path("out2"));
conf2.setOutputKeyClass(Text.class);
conf2.setOutputValueClass(NullWritable.class);
conf2.setMapperClass(Mapper2.class);
conf2.setNumReduceTasks(0);
Job j1 = new Job(conf);
Job j2 = new Job(conf2);
j1.addDependingJob(j2);
jc.addJob(j1);
jc.run()
}
}