处理结果入库
要求：将上述统计分析的结果数据保存到 mySQL 数据库中。
步骤：
（1）确定Mysql服务开启正常
（2）通过navicat在Mysql中新建表格
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
|
create table jichang( day_id varchar(255), sale_nbr varchar(255), cnt varchar(255), round varchar(255))create table dailishang( day_id varchar(255), sale_nbr varchar(255), cnt varchar(255), round varchar(255))create table dailishang_h(day_id varchar(255),sale_nbr varchar(255),Sale_number int,)create table daili( day_id varchar(255), sale_nbr varchar(255), incnt int, inround int, outcnt int, outround int, lirun int) |
（3）通过sqoop将hive中的数据导入到mysql
|
1
2
3
4
5
6
7
8
|
bin/sqoop export \--connect jdbc:mysql://node01:3306/hive1 \--username root \--password **** \--table jichang \--num-mappers 1 \--export-dir /user/hive/warehouse/jichang \--input-fields-terminated-by "," |
（4）结果展示
- 统计每天各个机场的销售数量和销售金额。
- 统计每天各个代理商的销售数量和销售金额。
- 统计每天各个代理商的销售活跃度。
- 汇总统计 9 月 1 日到 9 月 15 日之间各个代理商的销售利润。
