美文网首页
java大数据之hive

java大数据之hive

作者: 这一刻_776b | 来源:发表于2020-01-15 09:18 被阅读0次

    一、Hive简介

    1.1 Hive是什么

    由Facebook开源的一款基于hadoop的用于统计海量结构化数据的一个数据仓库。

    (1)建立在Hadoop HDFS上的数据仓库基础架构

    (2)可以用来进行ETL

    (3)定义了类似于SQL,成为HQL

    (4)允许MapReduce自定义

    1.2 Hive官网

    http://hive.apache.org/

    1.3 Hive适用场景

    (1)日志分析:大部分互联网公司使用hive进行日志分析,包括百度、淘宝等。

    (2)统计网站一个时间段内的pv、uv

    (3)多维度数据分析

    (4)海量结构化数据离线分析

    1.4 Hive不合适场景

    (1)hive不是一个关系型数据库

    (2)Hive不适合做为在线事务处理(OLTP)的系统

    (3)Hive不适合做实时查询和行级更新的操作

    1.5 Hive的优点

    (1)简单容易上手:提供了类SQL查询语言HQL

    (2)可扩展:为超大数据集设计了计算/扩展能力(MR作为计算引擎,HDFS作为存储系统),一般情况下不需要重启服务Hive可以自由的扩展集群的规模。

    (3)提供统一的元数据管理

    (4)延展性:Hive支持用户自定义函数,用户可以根据自己的需求来实现自己的函数

    (5)容错:良好的容错性,节点出现问题SQL仍可完成执行

    1.6 Hive的缺点

    (1)hive的HQL表达能力有限

    1)迭代式算法无法表达,比如pagerank

    2)数据挖掘方面,比如kmeans

    (2)hive的效率比较低

    1)hive自动生成的mapreduce作业,通常情况下不够智能化

    2)hive调优比较困难,粒度较粗

    3)hive可控性差

    1.7 Hive的体系结构

    1.8 Hive支持的数据类型

    复杂类型

    | array_type

    | map_type

    | struct_type

    简单类型

    |TINYINT

    | SMALLINT

    | INT

    | BIGINT

    | BOOLEAN

    | FLOAT

    | DOUBLE

    | STRING

    1.9 Hive特点

    1.在HDFS上处理数据,但是元数据通常保存在关系型数据库中

    2.Hive被设计用来处理离线数据分析(OLAP)

    3.Hive提供了类似sql类型的语言HiveQL(HQL)用来进行查询操作。

    4.Hive具有易懂,快速,可伸缩,可扩展的特性

    1.10 Hive与传统数据库的对比

    二、Hive安装

    2.1 Hive安装地址

    1.Hive官网地址

    http://hive.apache.org/

    2.文档查看地址

    https://cwiki.apache.org/confluence/display/Hive/GettingStarted

    3.下载地址

    http://archive.apache.org/dist/hive/

    4.github地址

    https://github.com/apache/hive

    2.2 Hive安装部署

    1.Hive安装及配置

    (1)把apache-hive-1.2.1-bin.tar.gz上传到linux的/opt/software目录下

    (2)解压apache-hive-1.2.1-bin.tar.gz到/opt/module/目录下面

    [atguigu@hadoop102 software]$ tar -zxvf apache-hive-1.2.1-bin.tar.gz -C /opt/module/

    (3)修改apache-hive-1.2.1-bin.tar.gz的名称为hive

    [atguigu@hadoop102 module]$ mv apache-hive-1.2.1-bin/ hive

    (4)修改/opt/module/hive/conf目录下的hive-env.sh.template名称为hive-env.sh

    [atguigu@hadoop102 conf]$ mv hive-env.sh.template hive-env.sh

    (5)配置hive-env.sh文件

    (a)配置HADOOP_HOME路径

    export HADOOP_HOME=/opt/module/hadoop-2.7.2

    (b)配置HIVE_CONF_DIR路径

    export HIVE_CONF_DIR=/opt/module/hive/conf

    2.Hadoop集群配置

    (1)必须启动hdfs和yarn

    [atguigu@hadoop102 hadoop-2.7.2]$ sbin/start-dfs.sh

    [atguigu@hadoop103 hadoop-2.7.2]$ sbin/start-yarn.sh

    (2)在HDFS上创建/tmp和/user/hive/warehouse两个目录并修改他们的同组权限可写

    [atguigu@hadoop102 hadoop-2.7.2]$ bin/hadoop fs -mkdir /tmp

    [atguigu@hadoop102 hadoop-2.7.2]$ bin/hadoop fs -mkdir -p /user/hive/warehouse

    [atguigu@hadoop102 hadoop-2.7.2]$ bin/hadoop fs -chmod g+w /tmp

    [atguigu@hadoop102 hadoop-2.7.2]$ bin/hadoop fs -chmod g+w /user/hive/warehouse

    3.Hive基本操作

    (1)启动hive

    [atguigu@hadoop102 hive]$ bin/hive

    (2)查看数据库

    hive> show databases;

    (3)打开默认数据库

    hive> use default;

    (4)显示default数据库中的表

    hive> show tables;

    (5)创建一张表

    hive> create table student(id int, name string);

    (6)显示数据库中有几张表

    hive> show tables;

    (7)查看表的结构

    hive> desc student;

    (8)向表中插入数据

    hive> insert into student values(1000,"ss");

    (9)查询表中数据

    hive> select * from student;

    (10)退出hive

    hive> quit;

    2.3将本地文件导入Hive案例

    需求

    将本地/opt/module/datas/student.txt这个目录下的数据导入到hive的student(id int, name string)表中。

    1.数据准备

    在/opt/module/datas这个目录下准备数据

    (1)在/opt/module/目录下创建datas

    [atguigu@hadoop102 module]$ mkdir datas

    (2)在/opt/module/datas/目录下创建student.txt文件并添加数据

    [atguigu@hadoop102 datas]$ touch student.txt

    [atguigu@hadoop102 datas]$ vi student.txt

    1001 zhangshan

    1002 lishi

    1003 zhaoliu

    注意以tab键间隔。

    2.Hive实际操作

    (1)启动hive

    [atguigu@hadoop102 hive]$ bin/hive

    (2)显示数据库

    hive> show databases;

    (3)使用default数据库

    hive> use default;

    (4)显示default数据库中的表

    hive> show tables;

    (5)删除已创建的student表

    hive> drop table student;

    (6)创建student表, 并声明文件分隔符’\t’

    hive> create table student(id int, name string) ROW FORMAT DELIMITED FIELDS TERMINATED

     BY '\t';

    (7)加载/opt/module/datas/student.txt 文件到student数据库表中。

    hive> load data local inpath '/opt/module/datas/student.txt' into table student;

    (8)Hive查询结果

    hive> select * from student;

    OK

    1001 zhangshan

    1002 lishi

    1003 zhaoliu

    Time taken: 0.266 seconds, Fetched: 3 row(s)

    3.遇到的问题

    再打开一个客户端窗口启动hive,会产生java.sql.SQLException异常。

    Exception in thread "main" java.lang.RuntimeException: java.lang.RuntimeException:

     Unable to instantiate

     org.apache.hadoop.hive.ql.metadata.SessionHiveMetaStoreClient

            at org.apache.hadoop.hive.ql.session.SessionState.start(SessionState.java:522)

            at org.apache.hadoop.hive.cli.CliDriver.run(CliDriver.java:677)

            at org.apache.hadoop.hive.cli.CliDriver.main(CliDriver.java:621)

            at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)

            at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)

            at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)

            at java.lang.reflect.Method.invoke(Method.java:606)

            at org.apache.hadoop.util.RunJar.run(RunJar.java:221)

            at org.apache.hadoop.util.RunJar.main(RunJar.java:136)

    Caused by: java.lang.RuntimeException: Unable to instantiate org.apache.hadoop.hive.ql.metadata.SessionHiveMetaStoreClient

            at org.apache.hadoop.hive.metastore.MetaStoreUtils.newInstance(MetaStoreUtils.java:1523)

            at org.apache.hadoop.hive.metastore.RetryingMetaStoreClient.<init>(RetryingMetaStoreClient.java:86)

            at org.apache.hadoop.hive.metastore.RetryingMetaStoreClient.getProxy(RetryingMetaStoreClient.java:132)

            at org.apache.hadoop.hive.metastore.RetryingMetaStoreClient.getProxy(RetryingMetaStoreClient.java:104)

            at org.apache.hadoop.hive.ql.metadata.Hive.createMetaStoreClient(Hive.java:3005)

            at org.apache.hadoop.hive.ql.metadata.Hive.getMSC(Hive.java:3024)

            at org.apache.hadoop.hive.ql.session.SessionState.start(SessionState.java:503)

    ... 8 more

    原因是,Metastore默认存储在自带的derby数据库中,推荐使用MySQL存储Metastore;

    2.4 MySql安装

    2.4.1安装包准备

    1.查看mysql是否安装,如果安装了,卸载mysql

    (1)查看

    [root@hadoop102桌面]# rpm -qa|grep mysql

    mysql-libs-5.1.73-7.el6.x86_64

    (2)卸载

    [root@hadoop102桌面]# rpm -e --nodeps mysql-libs-5.1.73-7.el6.x86_64

    2.解压mysql-libs.zip文件到当前目录

    [root@hadoop102 software]# unzip mysql-libs.zip

    [root@hadoop102 software]# ls

    mysql-libs.zip

    mysql-libs

    3.进入到mysql-libs文件夹下

    [root@hadoop102 mysql-libs]# ll

    总用量76048

    -rw-r--r--. 1 root root 18509960 3月  26 2015 MySQL-client-5.6.24-1.el6.x86_64.rpm

    -rw-r--r--. 1 root root  3575135 12月  1 2013 mysql-connector-java-5.1.27.tar.gz

    -rw-r--r--. 1 root root 55782196 3月  26 2015 MySQL-server-5.6.24-1.el6.x86_64.rpm

    2.4.2安装MySql服务器

    1.安装mysql服务端

    [root@hadoop102 mysql-libs]# rpm -ivh MySQL-server-5.6.24-1.el6.x86_64.rpm

    2.查看产生的随机密码

    [root@hadoop102 mysql-libs]# cat /root/.mysql_secret

    OEXaQuS8IWkG19Xs

    3.查看mysql状态

    [root@hadoop102 mysql-libs]# service mysql status

    4.启动mysql

    [root@hadoop102 mysql-libs]# service mysql start

    2.4.3安装MySql客户端

    1.安装mysql客户端

    [root@hadoop102 mysql-libs]# rpm -ivh MySQL-client-5.6.24-1.el6.x86_64.rpm

    2.链接mysql

    [root@hadoop102 mysql-libs]# mysql -uroot -pOEXaQuS8IWkG19Xs

    3.修改密码

    mysql>SET PASSWORD=PASSWORD('000000');

    4.退出mysql

    mysql>exit

    2.4.4 MySql中user表中主机配置

    配置只要是root用户+密码,在任何主机上都能登录MySQL数据库。

    1.进入mysql

    [root@hadoop102 mysql-libs]# mysql -uroot -p000000

    2.显示数据库

    mysql>show databases;

    3.使用mysql数据库

    mysql>use mysql;

    4.展示mysql数据库中的所有表

    mysql>show tables;

    5.展示user表的结构

    mysql>desc user;

    6.查询user表

    mysql>select User, Host, Password from user;

    7.修改user表,把Host表内容修改为%

    mysql>update user set host='%' where host='localhost';

    8.删除root用户的其他host

    mysql>delete from user where Host='hadoop102';

    mysql>delete from user where Host='127.0.0.1';

    mysql>delete from user where Host='::1';

    9.刷新

    mysql>flush privileges;

    10.退出

    mysql>quit;

    2.5 Hive元数据配置到MySql

    2.5.1驱动拷贝

    1.在/opt/software/mysql-libs目录下解压mysql-connector-java-5.1.27.tar.gz驱动包

    [root@hadoop102 mysql-libs]# tar -zxvf mysql-connector-java-5.1.27.tar.gz

    2.拷贝/opt/software/mysql-libs/mysql-connector-java-5.1.27目录下的mysql-connector-java-5.1.27-bin.jar到/opt/module/hive/lib/

    [root@hadoop102 mysql-connector-java-5.1.27]# cp mysql-connector-java-5.1.27-bin.jar

     /opt/module/hive/lib/

    2.5.2配置Metastore到MySql

    1.在/opt/module/hive/conf目录下创建一个hive-site.xml

    [atguigu@hadoop102 conf]$ touch hive-site.xml

    [atguigu@hadoop102 conf]$ vi hive-site.xml

    2.根据官方文档配置参数,拷贝数据到hive-site.xml文件中

    https://cwiki.apache.org/confluence/display/Hive/AdminManual+MetastoreAdmin

    <?xml version="1.0"?>

    <?xml-stylesheet type="text/xsl" href="configuration.xsl"?>

    <configuration>

    <property>

      <name>javax.jdo.option.ConnectionURL</name>

      <value>jdbc:mysql://hadoop102:3306/metastore?createDatabaseIfNotExist=true</value>

      <description>JDBC connect string for a JDBC metastore</description>

    </property>

    <property>

      <name>javax.jdo.option.ConnectionDriverName</name>

      <value>com.mysql.jdbc.Driver</value>

      <description>Driver class name for a JDBC metastore</description>

    </property>

    <property>

      <name>javax.jdo.option.ConnectionUserName</name>

      <value>root</value>

      <description>username to use against metastore database</description>

    </property>

    <property>

      <name>javax.jdo.option.ConnectionPassword</name>

      <value>000000</value>

      <description>password to use against metastore database</description>

    </property>

    </configuration>

    3.配置完毕后,如果启动hive异常,可以重新启动虚拟机。(重启后,别忘了启动hadoop集群)

    2.5.3多窗口启动Hive测试

    1.先启动MySQL

    [atguigu@hadoop102 mysql-libs]$ mysql -uroot -p000000

    查看有几个数据库

    mysql> show databases;

    +--------------------+

    | Database           |

    +--------------------+

    | information_schema |

    | mysql             |

    | performance_schema |

    | test               |

    +--------------------+

    2.再次打开多个窗口,分别启动hive

    [atguigu@hadoop102 hive]$ bin/hive

    3.启动hive后,回到MySQL窗口查看数据库,显示增加了metastore数据库

    mysql> show databases;

    +--------------------+

    | Database           |

    +--------------------+

    | information_schema |

    | metastore          |

    | mysql             |

    | performance_schema |

    | test               |

    +--------------------+

    2.6 HiveJDBC访问

    2.6.1 启动hiveserver2服务

    [atguigu@hadoop102 hive]$ bin/hiveserver2

    2.6.2 启动beeline

    [atguigu@hadoop102 hive]$ bin/beeline

    Beeline version 1.2.1 by Apache Hive

    beeline>

    2.6.3 连接hiveserver2

    beeline> !connect jdbc:hive2://hadoop102:10000(回车)

    Connecting to jdbc:hive2://hadoop102:10000

    Enter username for jdbc:hive2://hadoop102:10000: atguigu(回车)

    Enter password for jdbc:hive2://hadoop102:10000: (直接回车)

    Connected to: Apache Hive (version 1.2.1)

    Driver: Hive JDBC (version 1.2.1)

    Transaction isolation: TRANSACTION_REPEATABLE_READ

    0: jdbc:hive2://hadoop102:10000> show databases;

    +----------------+--+

    | database_name  |

    +----------------+--+

    | default        |

    | hive_db2       |

    +----------------+--+

    2.7 Hive常用交互命令

    1.“-e”不进入hive的交互窗口执行sql语句

    [atguigu@hadoop102 hive]$ bin/hive -e "select id from student;"

    2.“-f”执行脚本中sql语句

    (1)在/opt/module/datas目录下创建hivef.sql文件

    [atguigu@hadoop102 datas]$ touch hivef.sql

    文件中写入正确的sql语句

    select *from student;

    (2)执行文件中的sql语句

    [atguigu@hadoop102 hive]$ bin/hive -f /opt/module/datas/hivef.sql

    (3)执行文件中的sql语句并将结果写入文件中

    [atguigu@hadoop102 hive]$ bin/hive -f /opt/module/datas/hivef.sql  > /opt/module/datas/hive_result.txt

    2.8 Hive其他命令操作

    1.退出hive窗口:

    hive(default)>exit;

    hive(default)>quit;

    在新版的hive中没区别了,在以前的版本是有的:

    exit:先隐性提交数据,再退出;

    quit:不提交数据,退出;

    2.在hive cli命令窗口中如何查看hdfs文件系统

    hive(default)>dfs -ls /;

    3.在hive cli命令窗口中如何查看本地文件系统

    hive(default)>! ls /opt/module/datas;

    4.查看在hive中输入的所有历史命令

    (1)进入到当前用户的根目录/root或/home/atguigu

    (2)查看. hivehistory文件

    [atguigu@hadoop102 ~]$ cat .hivehistory

    2.9 Hive常见属性配置

    2.9.1 Hive数据仓库位置配置

    1)Default数据仓库的最原始位置是在hdfs上的:/user/hive/warehouse路径下。

    2)在仓库目录下,没有对默认的数据库default创建文件夹。如果某张表属于default数据库,直接在数据仓库目录下创建一个文件夹。

    3)修改default数据仓库原始位置(将hive-default.xml.template如下配置信息拷贝到hive-site.xml文件中)。

    <property>

    <name>hive.metastore.warehouse.dir</name>

    <value>/user/hive/warehouse</value>

    <description>location of default database for the warehouse</description>

    </property>

    配置同组用户有执行权限

    bin/hdfs dfs -chmod g+w /user/hive/warehouse

    2.9.2查询后信息显示配置

    1)在hive-site.xml文件中添加如下配置信息,就可以实现显示当前数据库,以及查询表的头信息配置。

    <property>

    <name>hive.cli.print.header</name>

    <value>true</value>

    </property>

    <property>

    <name>hive.cli.print.current.db</name>

    <value>true</value>

    </property>

    2)重新启动hive,对比配置前后差异。

    (1)配置前,如图6-2所示

    图6-2 配置前(2)配置后 如图6-3所示

    2.9.3 Hive运行日志信息配置

    1.Hive的log默认存放在/tmp/atguigu/hive.log目录下(当前用户名下)

    2.修改hive的log存放日志到/opt/module/hive/logs

    (1)修改/opt/module/hive/conf/hive-log4j.properties.template文件名称为

    hive-log4j.properties

    [atguigu@hadoop102 conf]$ pwd

    /opt/module/hive/conf

    [atguigu@hadoop102 conf]$ mv hive-log4j.properties.template hive-log4j.properties

    (2)在hive-log4j.properties文件中修改log存放位置

    hive.log.dir=/opt/module/hive/logs

    2.9.4参数配置方式

    1.查看当前所有的配置信息

    hive>set;

    2.参数的配置三种方式

    (1)配置文件方式

    默认配置文件:hive-default.xml

    用户自定义配置文件:hive-site.xml

    注意:用户自定义配置会覆盖默认配置。另外,Hive也会读入Hadoop的配置,因为Hive是作为Hadoop的客户端启动的,Hive的配置会覆盖Hadoop的配置。配置文件的设定对本机启动的所有Hive进程都有效。

    (2)命令行参数方式

    启动Hive时,可以在命令行添加-hiveconf param=value来设定参数。

    例如:

    [atguigu@hadoop103 hive]$ bin/hive -hiveconf mapred.reduce.tasks=10;

    注意:仅对本次hive启动有效

    查看参数设置:

    hive (default)> set mapred.reduce.tasks;

    (3)参数声明方式

    可以在HQL中使用SET关键字设定参数

    例如:

    hive (default)> set mapred.reduce.tasks=100;

    注意:仅对本次hive启动有效。

    查看参数设置

    hive (default)> set mapred.reduce.tasks;

    上述三种设定方式的优先级依次递增。即配置文件<命令行参数<参数声明。注意某些系统级的参数,例如log4j相关的设定,必须用前两种方式设定,因为那些参数的读取在会话建立以前已经完成了。、

    第3章Hive数据类型

    3.1基本数据类型

    对于Hive的String类型相当于数据库的varchar类型,该类型是一个可变的字符串,不过它不能声明其中最多能存储多少个字符,理论上它可以存储2GB的字符数。

    3.2集合数据类型

    Hive有三种复杂数据类型ARRAY、MAP 和 STRUCT。ARRAY和MAP与Java中的Array和Map类似,而STRUCT与C语言中的Struct类似,它封装了一个命名字段集合,复杂数据类型允许任意层次的嵌套。

    案例实操

    [if !supportLists]1) [endif]假设某表有如下一行,我们用JSON格式来表示其数据结构。在Hive下访问的格式为

    {

        "name": "songsong",

    "friends": ["bingbing" , "lili"] ,       //列表Array,

    "children": {                      //键值Map,

            "xiao song": 18 ,

            "xiaoxiao song": 19

        }

    "address": {                      //结构Struct,

            "street": "hui long guan" ,

            "city": "beijing"

        }

    }

    2)基于上述数据结构,我们在Hive里创建对应的表,并导入数据。

    创建本地测试文件test.txt

    songsong,bingbing_lili,xiao song:18_xiaoxiao song:19,hui long guan_beijing

    yangyang,caicai_susu,xiao yang:18_xiaoxiao yang:19,chao yang_beijing

    注意:MAP,STRUCT和ARRAY里的元素间关系都可以用同一个字符表示,这里用“_”。

    3)Hive上创建测试表test

    create table test(

    name string,

    friends array<string>,

    children map<string, int>,

    address struct<street:string, city:string>

    )

    row format delimited fields terminated by ','

    collection items terminated by '_'

    map keys terminated by ':'

    lines terminated by '\n';

    字段解释:

    row format delimited fields terminated by ','  --列分隔符

    collection items terminated by '_'   --MAP STRUCT和 ARRAY 的分隔符(数据分割符号)

    map keys terminated by ':' -- MAP中的key与value的分隔符

    lines terminated by '\n'; --行分隔符

    4)导入文本数据到测试表

    hive (default)> load data local inpath ‘/opt/module/datas/test.txt’into table test

    5)访问三种集合列里的数据,以下分别是ARRAY,MAP,STRUCT的访问方式

    hive (default)> select friends[1],children['xiao song'],address.city from test

    where name="songsong";

    OK

    _c0     _c1     city

    lili    18      beijing

    Time taken: 0.076 seconds, Fetched: 1 row(s)

    3.3类型转化

    Hive的原子数据类型是可以进行隐式转换的,类似于Java的类型转换,例如某表达式使用INT类型,TINYINT会自动转换为INT类型,但是Hive不会进行反向转化,例如,某表达式使用TINYINT类型,INT不会自动转换为TINYINT类型,它会返回错误,除非使用CAST操作。

    1.隐式类型转换规则如下

    (1)任何整数类型都可以隐式地转换为一个范围更广的类型,如TINYINT可以转换成INT,INT可以转换成BIGINT。

    (2)所有整数类型、FLOAT和STRING类型都可以隐式地转换成DOUBLE。

    (3)TINYINT、SMALLINT、INT都可以转换为FLOAT。

    (4)BOOLEAN类型不可以转换为任何其它的类型。

    2.可以使用CAST操作显示进行数据类型转换

    例如CAST('1' AS INT)将把字符串'1' 转换成整数1;如果强制类型转换失败,如执行CAST('X' AS INT),表达式返回空值 NULL。

    第4章DDL数据定义

    4.1创建数据库

    1)创建一个数据库,数据库在HDFS上的默认存储路径是/user/hive/warehouse/*.db。

    hive (default)> create database db_hive;

    2)避免要创建的数据库已经存在错误,增加if not exists判断。(标准写法)

    hive (default)> create database db_hive;

    FAILED: Execution Error, return code 1 from org.apache.hadoop.hive.ql.exec.DDLTask. Database db_hive already exists

    hive (default)> create database if not exists db_hive;

    3)创建一个数据库,指定数据库在HDFS上存放的位置

    hive (default)> create database db_hive2 location '/db_hive2.db';

    4.2查询数据库

    4.2.1显示数据库

    1.显示数据库

    hive> show databases;

    2.过滤显示查询的数据库

    hive> show databases like 'db_hive*';

    OK

    db_hive

    db_hive_1

    4.2.2查看数据库详情

    1.显示数据库信息

    hive> desc database db_hive;

    OK

    db_hive hdfs://hadoop102:9000/user/hive/warehouse/db_hive.db atguiguUSER

    2.显示数据库详细信息,extended

    hive> desc database extended db_hive;

    OK

    db_hive hdfs://hadoop102:9000/user/hive/warehouse/db_hive.db atguiguUSER

    40.3.3切换当前数据库

    hive (default)> use db_hive;

    4.3.3切换当前数据库

    hive (default)> use db_hive;

    4.3修改数据库

    用户可以使用ALTER DATABASE命令为某个数据库的DBPROPERTIES设置键-值对属性值,来描述这个数据库的属性信息。数据库的其他元数据信息都是不可更改的,包括数据库名和数据库所在的目录位置。

    hive (default)> alter database db_hive set dbproperties('createtime'='20170830');

    在hive中查看修改结果

    hive> desc database extended db_hive;

    db_name comment location        owner_name      owner_type      parameters

    db_hive         hdfs://hadoop102:8020/user/hive/warehouse/db_hive.db    atguigu USER    {createtime=20170830}

    4.4删除数据库

    1.删除空数据库

    hive>drop database db_hive2;

    2.如果删除的数据库不存在,最好采用 if exists判断数据库是否存在

    hive> drop database db_hive;

    FAILED: SemanticException [Error 10072]: Database does not exist: db_hive

    hive> drop database if exists db_hive2;

    3.如果数据库不为空,可以采用cascade命令,强制删除

    hive> drop database db_hive;

    FAILED: Execution Error, return code 1 from org.apache.hadoop.hive.ql.exec.DDLTask. InvalidOperationException(message:Database db_hive is not empty. One or more tables exist.)

    hive> drop database db_hive cascade;

    4.5创建表

    1.建表语法

    CREATE [EXTERNAL] TABLE [IF NOT EXISTS] table_name

    [(col_name data_type [COMMENT col_comment], ...)]

    [COMMENT table_comment]

    [PARTITIONED BY (col_name data_type [COMMENT col_comment], ...)]

    [CLUSTERED BY (col_name, col_name, ...)

    [SORTED BY (col_name [ASC|DESC], ...)] INTO num_buckets BUCKETS]

    [ROW FORMAT row_format]

    [STORED AS file_format]

    [LOCATION hdfs_path]

    2.字段解释说明 

    (1)CREATE TABLE 创建一个指定名字的表。如果相同名字的表已经存在,则抛出异常;用户可以用 IF NOT EXISTS 选项来忽略这个异常。

    (2)EXTERNAL关键字可以让用户创建一个外部表,在建表的同时指定一个指向实际数据的路径(LOCATION),Hive创建内部表时,会将数据移动到数据仓库指向的路径;若创建外部表,仅记录数据所在的路径,不对数据的位置做任何改变。在删除表的时候,内部表的元数据和数据会被一起删除,而外部表只删除元数据,不删除数据。

    (3)COMMENT:为表和列添加注释。

    (4)PARTITIONED BY创建分区表

    (5)CLUSTERED BY创建分桶表

    (6)SORTED BY不常用

    (7)ROW FORMAT

    DELIMITED [FIELDS TERMINATED BY char] [COLLECTION ITEMS TERMINATED BY char]

            [MAP KEYS TERMINATED BY char] [LINES TERMINATED BY char]

       | SERDE serde_name [WITH SERDEPROPERTIES (property_name=property_value, property_name=property_value, ...)]

    用户在建表的时候可以自定义SerDe或者使用自带的SerDe。如果没有指定ROW FORMAT 或者ROW FORMAT DELIMITED,将会使用自带的SerDe。在建表的时候,用户还需要为表指定列,用户在指定表的列的同时也会指定自定义的SerDe,Hive通过SerDe确定表的具体的列的数据。

    SerDe是Serialize/Deserilize的简称,目的是用于序列化和反序列化。

    (8)STORED AS指定存储文件类型

    常用的存储文件类型:SEQUENCEFILE(二进制序列文件)、TEXTFILE(文本)、RCFILE(列式存储格式文件)

    如果文件数据是纯文本,可以使用STORED AS TEXTFILE。如果数据需要压缩,使用 STORED AS SEQUENCEFILE。

    (9)LOCATION :指定表在HDFS上的存储位置。

    (10)LIKE允许用户复制现有的表结构,但是不复制数据。

    4.5.1管理表

    1.理论

    默认创建的表都是所谓的管理表,有时也被称为内部表。因为这种表,Hive会(或多或少地)控制着数据的生命周期。Hive默认情况下会将这些表的数据存储在由配置项hive.metastore.warehouse.dir(例如,/user/hive/warehouse)所定义的目录的子目录下。 当我们删除一个管理表时,Hive也会删除这个表中数据。管理表不适合和其他工具共享数据。

    2.案例实操

    (1)普通创建表

    create table if not exists student2(

    id int, name string

    )

    row format delimited fields terminated by '\t'

    stored as textfile

    location '/user/hive/warehouse/student2';

    (2)根据查询结果创建表(查询的结果会添加到新创建的表中)

    create table if not exists student3 as select id, name from student;

    (3)根据已经存在的表结构创建表

    create table if not exists student4 like student;

    (4)查询表的类型

    hive (default)> desc formatted student2;

    Table Type:             MANAGED_TABLE  

    4.5.2外部表

    1.理论

    因为表是外部表,所以Hive并非认为其完全拥有这份数据。删除该表并不会删除掉这份数据,不过描述表的元数据信息会被删除掉。

    2.管理表和外部表的使用场景

    每天将收集到的网站日志定期流入HDFS文本文件。在外部表(原始日志表)的基础上做大量的统计分析,用到的中间表、结果表使用内部表存储,数据通过SELECT+INSERT进入内部表。

    相关文章

      网友评论

          本文标题:java大数据之hive

          本文链接:https://www.haomeiwen.com/subject/ftjiactx.html