数据从Postgresql导入Hbase中
[*]下载sqoop
[*]下载Postgresql jdbc驱动，拷入sqoop下lib中
[*]
执行
sqoop import --connect jdbc:postgresql://172.16.1.141:5432/DB_SERVER --query "SELECT id,concat(f_mmsi,to_char(f_updatetime, 'YYYYMMHH12MISS')) as trackid,f_mmsi as mmsi,f_cog as cog,f_nav_status as navStatus,f_heading as heading,f_sog as sog,f_updatetime as updateTime,f_lon as lon,f_lat as lat FROMt_szhk_track_data WHERE \$CONDITIONS" --hbase-table tablename --column-family info--split-by id --hbase-row-key trackid --hbase-create-table --username postgres --password postgres
页:
[1]