HBase中怎么将已知表移植到另一张表中

本篇内容介绍了“HBase中怎么将已知表移植到另一张表中”的有关知识，在实际案例的操作过程中，不少人都会遇到这样的困境，接下来就让小编带领大家学习一下如何处理这些情况吧！希望大家仔细阅读，能够学有所成！

    将已经存在某张表，比如 blog，将此表中的数据“移植”到另外一张新表中。

/**
 * 将HBase中一张表的数据移植到另一张表中。
 * */
public class HBaseAndMapReduce4 {
	public static void main(String[] args) throws Exception {
		System.exit(run());
	}

	public static int run() throws Exception {
		Configuration conf = new Configuration();
		conf = HBaseConfiguration.create(conf);
		conf.set("hbase.zookeeper.quorum", "192.168.226.129");

		Job job = Job.getInstance(conf, "findFriend");
		job.setJarByClass(HBaseAndMapReduce4.class);
		
		//实例化scan对象。
		Scan scan = new Scan();
		scan.addColumn(Bytes.toBytes("article"), Bytes.toBytes("tags"));
		scan.addColumn(Bytes.toBytes("author"), Bytes.toBytes("nickname"));

		TableMapReduceUtil.initTableMapperJob("blog", scan, FindFriendMapper.class, 
				ImmutableBytesWritable.class, ImmutableBytesWritable.class,job);
		
		TableMapReduceUtil.initTableReducerJob("friend02", FindFriendReducer.class, job);
		
		checkTable(conf);
		return job.waitForCompletion(true) ? 0 : 1;
	}

	private static void checkTable(Configuration conf) throws Exception {
		Connection con = ConnectionFactory.createConnection(conf);
		Admin admin = con.getAdmin();
		TableName tn = TableName.valueOf("friend02");
		if (!admin.tableExists(tn)){
			HTableDescriptor htd = new HTableDescriptor(tn);
			HColumnDescriptor hcd = new HColumnDescriptor("person");
			htd.addFamily(hcd);
			admin.createTable(htd);
			System.out.println("表不存在，新创建表成功....");
		}
	}
	
	public static class FindFriendMapper extends TableMapper<ImmutableBytesWritable, ImmutableBytesWritable>{
		@Override
		//key是hbase中的行键
		//value是hbase中的所行键的所有数据
		protected void map(
				ImmutableBytesWritable key,
				Result value,
				Mapper<ImmutableBytesWritable, Result,ImmutableBytesWritable, ImmutableBytesWritable>.Context context)
				throws IOException, InterruptedException {
			
			ImmutableBytesWritable v = null;
			String[] kStrs = null;
			List<Cell> cs = value.listCells();
			for (Cell cell : cs) {
				if ("tags".equals(Bytes.toString(CellUtil.cloneQualifier(cell)))){
					kStrs = Bytes.toString(CellUtil.cloneValue(cell)).split(",");
				}
				else if ("nickname".equals(Bytes.toString(CellUtil.cloneQualifier(cell)))){
					v = new ImmutableBytesWritable(CellUtil.cloneValue(cell));
				}
			}
			for (String kStr : kStrs) {
				context.write(new ImmutableBytesWritable(Bytes.toBytes(kStr.toLowerCase())), v);
			}
			
		}
	}

	public static class FindFriendReducer extends
			TableReducer<ImmutableBytesWritable, ImmutableBytesWritable, ImmutableBytesWritable> {
		@Override
		protected void reduce(
				ImmutableBytesWritable key,
				Iterable<ImmutableBytesWritable> values,
				Reducer<ImmutableBytesWritable, ImmutableBytesWritable, ImmutableBytesWritable, Mutation>.Context context)
				throws IOException, InterruptedException {
			System.out.println(  "key--->"+key.get() );
			Put put = new Put(key.get());
			StringBuilder vStr = new StringBuilder();
			for (ImmutableBytesWritable value : values) {
				System.out.println( "value-->"+value.get() );
				vStr.append((vStr.length() > 0 ? ",":"") + Bytes.toString(value.get()));
			}
			put.addColumn(Bytes.toBytes("person"), Bytes.toBytes("nickname"),Bytes.toBytes(vStr.toString()));
			context.write(key, put);
		}
	}
}

“HBase中怎么将已知表移植到另一张表中”的内容就介绍到这里了，感谢大家的阅读。如果想了解更多行业相关的知识可以关注亿速云网站，小编将为大家输出更多高质量的实用文章！