阅读背景:

Mapreduce读取Hbase表,写数据到一个Hbase表中

来源:互联网 
public class LabelJob
{
    
    public static void main(String[] args)
        throws Exception
    {
        Job job = Job.getInstance(new Configuration());
        job.setJarByClass(LabelJob.class);
        job.setJobName("Hbase.LabelJob");
        
        Configuration conf = job.getConfiguration();
        conf.set("tablename", "product_tags");
        
        Scan scan = new Scan();
        scan.setCaching(500);
        scan.setCacheBlocks(false);
        //输入表
        TableMapReduceUtil.initTableMapperJob("tb_user", scan, LabelMapper.class, Text.class, Text.class, job);
        
        job.setReducerClass(LabelReducer.class);
        //输出表
        TableMapReduceUtil.initTableReducerJob("usertags", LabelReducer.class, job);
        job.waitForCompletion(true);
        
    }
    
}
public class LabelJob
{
    
    public sta



你的当前访问异常,请进行认证后继续阅读剩余内容。

分享到: