大数据数据仓库Hive基本使用

1、创建表

create table hive_wordcount(context string);

 

 

2、查看表

show tables;

 

 

3、查询表数据

 

 

4、查看刚才创建的Mysql数据库sparksql的表TBLS，可以发现已经有1条记录了，TBL_NAME 为hive_wordcount

 

 

从COLUMNS_V2表查看刚才创建的hive_wordcount表的字段。

 

5、加载数据到Hive表里

数据准备，就是前面用到的数据。 /home/data/hello.txt文件

 

 

load data local inpath  '/home/data/hello.txt'  into table hive_wordcount;

 

 

查看数据

 

 可以发现，已经有两行数据了。

 

6、查询统计单词个数功能

select word,count(1) from hive_wordcount lateral view explode(split(context,' ')) wc as word group by word
lateral view explode(): 该函数是把每行记录按照指定分隔符进行拆解。 split(context,' ')空格分隔。

 

 统计结果hello 2个，welcome 2个 world 1个

 

 

 然后访问8088端口

 

 总结： hive ql 提交执行后会生成mr作业，并在yarn上运行。对比MapReduce实现更简单，只需要使用HQL语句就行。