1、sqoop将关系数据库导入到hbase的参数说明
2、sqoop导入hbase的命令
sqoop import --connect jdbc:oracle:thin:@192.168.27.235:1521/orcl --username DATACENTER -P --table TEMP1 //这是指定sqoop的连接参数
--hbase-create-table --hbase-table temp1 --column-family info --hbase-row-key ID //这里是指定hbase的 参数
(1)测试用sqoop将oracle中的表导入到hbase中
1)原hbase中的标的内容如下
select * from TEMP1;
ID NAME
1 张三
2 李四
2)执行导入:
sqoop import --connect jdbc:oracle:thin:@192.168.27.235:1521/orcl --username DATACENTER -P --table TEMP1 --hbase-create-table --hbase-table temp1 --column-family info --hbase-row-key ID
说明:在这里通过 --hbase-row-key来指定rowkey是原表中的ID,通过--column-family来指定hbase中的col family是info
3)导入后的结果如下
从上图很清楚的看到:对应的原表中的ID作为了hbase中的rowkey,剩下的字段则为colfimaly的内容,value是安字节存储的,因此看到的是字节数据
3、sqoop导入到hbase采用bulkload的导入
sqoop import --driver com.mysql.jdbc.Driver --connect "jdbc:mysql://172.10.23.104:3306/cpp" --table tablename --username root --password root --hbase-table hbasetable --column-family info --hbase-row-key ID --hbase-create-table --hbase-bulkload -m 8
原文:http://www.cnblogs.com/ljy2013/p/4873978.html