EsFeeder.java 文件源码

@Override
public int run(String[] args) throws Exception{
    Configuration conf = super.getConf();
    optParser(args);

    conf.set("es.nodes", this.servers);
    conf.set("prefix",this.prefix);
    conf.set("es.resource", this.index + "/{"+this.prefix+"SiteName}");
    conf.set("es.mapping.id",this.prefix+"Id");

    Job job = Job.getInstance(conf,"Description");
    job.setJarByClass(EsFeeder.class);
    job.setMapperClass(datacentermr.EsFeederMapper.class);
    job.setSpeculativeExecution(false);

    job.setOutputFormatClass(EsOutputFormat.class);
    job.setOutputKeyClass(NullWritable.class);
    job.setMapOutputValueClass(MapWritable.class);

    job.setNumReduceTasks(0);
    FileInputFormat.addInputPath(job, new Path(this.input));

    System.exit(job.waitForCompletion(true) ? 0 : 1);
    return 0;
    }