impala-shell导入导出

迈不过友情╰ 2022-05-29 03:08 365阅读 0赞

impala-shell导入导出  
  
  
(tip:将select \* from config.price\_test limit 3，替换为需要导出的查询sql即可,分割符号可以自选)  
  
  
参数说明：  
　　• -q query （--query=query） 从命令行执行查询，不进入impala-shell  
　　• -d default\_db （--database=default\_db） 指定数据库  
　　• -B（--delimited）去格式化输出  
　　• --output\_delimiter=character 指定分隔符  
　　• --print\_header 打印列名  
　　• -f query\_file（--query\_file=query\_file）执行查询文件，以分号分隔  
　　• -o filename （--output\_file filename） 结果输出到指定文件  
  
  
  
  
  
  
1、导出  
  
  
1.1 导出结果到csv  
  
  
impala-shell -q "select id,price,name,dtime from config.price\_test limit 3" -B --output\_delimiter="," --print\_header -o /var/testimpalaout.csv  
  
  
1.2 导出结果到excle  
  
  
impala-shell -q "select id,price,name,dtime from config.price\_test limit 3" -B --output\_delimiter="\\t" --print\_header -o /var/testimpalaout.xlsx  
  
  
  
  
  
  
  
  
  
  
2、导入  
  
  
2.1 hadoop创建文件夹  
  
  
hadoop fs -mkdir /tmp/price\_txternal  
  
  
  
  
2.2 本地文件上传hadoop  
  
  
hadoop fs -put /var/testimpalaout.csv /tmp/price\_txternal  
  
  
  
  
2.3 创建临时表(无分区，普通文本表)  
impala-shell ,进入impala-shell数据库，（分隔符，自定义）  
  
  
CREATE TABLE config.price\_test\_ls (                                           
  id INT,                                                                 
  price DOUBLE,                                                           
  name VARCHAR(200),                                                      
  dtime TIMESTAMP                                                         
)   
row format delimited fields terminated by ','  
location '/tmp/price\_txternal';  
  
  
2.4 导入分区表  
  
  
  
  
INSERT INTO config.price\_test PARTITION(DAY = 20170701, MINUTE = cast('0000' as char(4)) )   
SELECT   
  id,  
  price,  
  NAME,  
  dtime   
FROM  
  config.price\_test\_ls   
  
  
2.5 删除临时表  
  
  
drop table config.price\_test\_ls;