sqoop从phoenix抽取数据到hdfs
sqoop import \
--driver org.apache.phoenix.jdbc.PhoenixDriver \
--connect jdbc:phoenix:192.168.111.45:2181 \
--query "select cs_mine_code, cs_data_time,ss_station_code,ss_transducer_code,ss_transducer_state,ss_analog_value from AQSS_m WHERE substr(cs_data_time,0,10)='2020-07-24' and \$CONDITIONS" \
--target-dir /origin_data/phoenix/dwd/aqss_m/2020-07-24/ \
--delete-target-dir \
--num-mappers 1 \
--direct \
--fields-terminated-by ','
2021-01-28 04:24:54
4KB
hive
1