Put put = new Put(Bytes.toBytes(name+","+age));
put.add(t1_fam,t1_qua,Bytes.toBytes(age));
context.write(putTable, put);
// write to the second table row=name+webPage,value=webPage
putTable = new ImmutableBytesWritable(table2);
put = new Put(Bytes.toBytes(name+","+webPage));
put.add(t2_fam,t2_qua,Bytes.toBytes(webPage));
context.write(putTable, put);
}
}
上面的代码只用了一个Mapper，同时写入两个HBase表中。这里的要点是设置Mapper的输出key和value的类型，按照上面的代码类型为：ImmutableBytesWritable和Writable,而且在job的声明处要设置输出类型：job.setOutputFormatClass(MultiTableOutputFormat.class);
如何运行上面的程序？
(1)在HBase中创建两张表:
create 'table1','info'
create 'table2','info'
(2)ImportToHB的输入参数如下：
hdfs://master:9000/user/fansy/input/info.dat table1 info age table2 info webPage
(3)直接在eclipse中运行
运行后在HBase中察看输出的数据如下：
