Sqoop MySQL to HBase

说明

假设 table1 是 MySQL 里 demo 库里的表,其主键字段为 t_id, 需要导到 HBase 的 htable1 表。

指定表名导入

sqoop import \
    -D sqoop.hbase.add.row.key=true \
    --connect "jdbc:mysql://192.168.0.100:3306/demo?characterEncoding=utf-8" --username nate --password 123123 \
    --table table1 \
    --hbase-table htable1 \
    --hbase-row-key t_id --split-by t_id -m 7 \
    --column-family cf

指定查询语句导入

sqoop import \
    -D sqoop.hbase.add.row.key=true \
    --connect "jdbc:mysql://192.168.0.100:3306/demo?characterEncoding=utf-8" --username nate --password 123123 \
    --query "select * from table1 where t_id > 0 and \$CONDITIONS" \
    --hbase-table htable1 \
    --hbase-row-key t_id --split-by t_id -m 7 \
    --column-family cf

split-by 字段为 text

sqoop import \
    -D sqoop.hbase.add.row.key=true \
    -D org.apache.sqoop.splitter.allow_text_splitter=true \
    --connect "jdbc:mysql://192.168.0.100:3306/demo?characterEncoding=utf-8" --username nate --password 123123 \
    --table table1 \
    --hbase-table htable1 \
    --hbase-row-key t_id --split-by t_id -m 7 \
    --column-family cf