sqoop将关系型的数据库得数据导入到hbase中

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

巴特西

sqoop将关系型的数据库得数据导入到hbase中

最新文章

热门文章