设为首页 加入收藏

TOP

mapreduce输入源为多hbase数据表 输出目标为多hbase数据表
2019-05-07 13:43:44 】 浏览:52
Tags:mapreduce 输入 hbase 数据 输出 目标

多输入源(多个scan)配置:在job中配置

TableMapReduceUtil.initTableMapperJob(model.getScans(), model.getMapperClass(), model.getOutputKeyClass(),
				model.getOutputValueClass(), job);

其中第一个参数类型 List<Scan>

多输出源配置:job中配置

 job.setOutputValueClass(Put.class);
        job.setOutputFormatClass(MultiTableOutputFormat.class);
        job.setReducerClass(InterReducer.class);


redecu过程中根据条件确定要存储的表名 例如:

ImmutableBytesWritable ib = new ImmutableBytesWritable();
                ib.set(表名);
                context.write(ib, put);


】【打印繁体】【投稿】【收藏】 【推荐】【举报】【评论】 【关闭】 【返回顶部
上一篇R语言连接hbase问题疑解 下一篇HBase中的术语详解

最新文章

热门文章

Hot 文章

Python

C 语言

C++基础

大数据基础

linux编程基础

C/C++面试题目