LoveDriver.java

package HbaseMR;


import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.HBaseConfiguration;
import org.apache.hadoop.hbase.client.Put;
import org.apache.hadoop.hbase.client.Scan;
import org.apache.hadoop.hbase.io.ImmutableBytesWritable;
import org.apache.hadoop.hbase.mapreduce.TableMapReduceUtil;
import org.apache.hadoop.mapreduce.Job;
import org.apache.hadoop.util.Tool;
import org.apache.hadoop.util.ToolRunner;


public class LoveDriver implements Tool {
  private Configuration conf;

  public static void main(String[] args) throws Exception {
    int status = ToolRunner.run(new LoveDriver(), args);
    System.exit(status);
  }
  //设置配置

  //业务逻辑
  public int run(String[] strings) throws Exception {
    //1.创建任务
    Job job = Job.getInstance(conf);
    //2.指定运行的主类
    job.setJarByClass(LoveDriver.class);
    //3.配置job，采用scan方式扫描该表
    Scan scan = new Scan();
    //4.设置Mapper
    TableMapReduceUtil.initTableMapperJob("love", scan, ReadLoveMapper.class,
        ImmutableBytesWritable.class, Put.class, job);
    //5.设置Reducer
    TableMapReduceUtil.initTableReducerJob("lovemr", WriteLoveReducer.class, job);
    //6.设置reducerTask的个数
    job.setNumReduceTasks(1);
    //7.执行任务
    boolean b = job.waitForCompletion(true);
    return b ? 0 : 1;
  }  public void setConf(Configuration configuration) {
    this.conf = HBaseConfiguration.create(configuration);
  }

  //拿到配置
  public Configuration getConf() {
    return this.conf;
  }

}