作者:为谁落慕 | 来源:互联网 | 2023-08-28 16:31
我们把stu表导入到hive中,使用如下命令: sqoopimport--connectjdbc:mysql:sunchen11test--usernamehive--passw
我们把stu表导入到hive中,使用如下命令:
sqoop import --connect jdbc:mysql://sunchen11/test--username hive --password hive --table stu -m 1 --hive-import
我们在hive中对导入的表进行处理前,
先在hive中创建一个cour表,
表的结构如下:
这是一个课程表,里面有学号(id),有课程名称(canme),学生姓名(name)
cour的数据从本地导入,命令:load data local inpath '/home/hadoop/djt/.1,txt';
查看一下导入数据是否成功:
导入成功。
hive中对导入的表进行处理:通过cour和stu得到成绩表t1
逻辑:stu表中有id,name,score字段
cour表中有cid,cname,name字段
t1表中有id,sanme,cscore
命令如下:
hive> createtable t1
> as
> select c.name as stuname,c.cname ascourname,s.score from cour c
> join stu s on (s.id = c.cid);