清洗数据绑定到hive再到mysql

create external table mydb.access(ip string,day string,url string,upflow string) row format delimited fields terminated by ','；

load data inpath '/hive/output/' into table mydb.access;

create external table mydb.upflow (ip string,sum string) row format delimited fields terminated by ','；

insert into mydb.upflow select ip, sum(upflow) as sum from mydb.access group by ip order by sum desc;

create table upflow (
  ip varchar(200),
  sum varchar(200)
);

sqoop export --connect jdbc:mysql://localhost:3306/test --username root --password admin --table uv_info --export-dir /user/hive/warehouse/uv/dt=2011-08-03