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()
}
}