zoukankan      html  css  js  c++  java
  • 一起学Hive——创建内部表、外部表、分区表和分桶表及导入数据

    Hive本身并不存储数据,而是将数据存储在Hadoop的HDFS中,表名对应HDFS中的目录/文件。根据数据的不同存储方式,将Hive表分为外部表、内部表、分区表和分桶表四种数据模型。每种数据模型各有优缺点。通过create user命令创建user表时,会在HDFS中生成一个user目录/文件。

    外部表

    数据不由Hive管理,使用drop命令删除一个表时,只是把表的元数据给删除了,而表的数据不会删除。
    创建外部表的SQL语句:

    create external table bigdata17_user(
    userid int,
    username string,
    fullname string)  
    row format delimited fields terminated by ','   
    lines terminated by '
    ';
    

    在hive的命令行中执行 show tables;sql语句,会看到bigdata17_user的表。
    hive table

    通过执行hadoop fs -ls /user/hive/warehouse/bigdata17.db/bigdata17_user 命令,可以看到在HDFS中有一个bigdata17_user的目录。这时候文件夹下面是没有数据的,因为还没有导入数据。bigdata17.db是数据库名,hive默认的数据库是default。
    hive table
    执行SQL语句:load data inpath '/data/user.csv' overwrite into table bigdata17_user;导入数据到bigdata17_user表中。

    执行hadoop fs -ls /user/hive/warehouse/bigdata17.db/bigdata17_user命令,就看到该目录下面有个user.csv的文件。
    hive table
    通过drop table bigdata17_user;语句删除表。
    然后执行show tables语句,发现该表已经不存在。

    我们再次执行hadoop fs -ls /user/hive/warehouse/bigdata17.db/bigdata17_user,发现bigdata17_user目录还存在,目录中还有user.csv文件。
    hive table
    通过上述的操作,验证了使用drop删除表时是不会删除外部表的数据。而我们要恢复外部表只需再次执行创建bigdat17_user表的SQL即可:

    create external table bigdata17_user(
    userid int,
    username string,
    fullname string)  
    row format delimited fields terminated by ','   
    lines terminated by '
    ';
    

    内部表

    内部表(有些人会翻译成管理表)的数据由hive管理,当使用drop删除表时,会把表的元数据和数据一起删除,数据无法恢复,因此一定要慎用drop删除内部表。

    创建内部表的sql语句:

    create table bigdata17_user( userid int, username string, fullname string)
    row format delimited fields terminated by ','
    lines terminated by '
    ';
    

    和外部表创建的语法基本一样,只是创建外部表需要使用external关键字。没有external关键字则是创建内部表。

    分区表

    内部表和外部表都可以使用分区的功能,使用分区的内部或外部表称为分区表。
    创建分区表的语句:

    create external table bigdata17_user_partition(
    username string,
    fullname string)
    partitioned by(userid string)
    row format delimited fields terminated by ','   
    lines terminated by '
    ';
    

    往分区表导入数据分为静态分区导入和动态分区导入,静态分区是在导入语句中指定分区值,例如:

    insert overwrite table bigdata17-user_parttion
     partition(userid=1)
     select username ,fullname from bigdata17_user;
    

    该语句的分区值默认是1,如果有多个分区值,必须写多个sql语句,效率低下。

    一般情况在我们都是使用动态分区导入数据,
    在导入数据之前必须执行下面的两条语句让hive支持动态分区功能,默认是不支持动态分区的。

    set hive.exec.dynamic.partition=true;
    set hive.exec.dynamic.partition.mode=nonstrict;
    

    动态分区导入数据的sql语句:

    insert overwrite table bigdata17_user_partition
     partition(userid)
     select username ,fullname,userid from bigdata17_user;
    

    我们来看下分区表的数据在hdfs中是以何种形式组织存放的,执行hadoop fs -ls /user/hive/warehouse/bigdata17.db/bigdata17_user_partition命令,会看到下图的内容:
    hive table
    因为bigdata17_user_partition表是按照userid字段进行分区的,bigdata17_user_partition一共有1、2和3的三个数值,因此有3个文件。由此可见,分区字段有多少个不同的值,就有几个文件。相同分区的数据存放在同一个文件中。

    注意:在使用insert overwrite table select方式导入数据到分区表时,有多个分区字段时,分区partition中的字段顺序必须和select字段的顺序一致。

    分桶表

    分桶是将某个字段取哈希值,值相同的数据分发到一个桶中。在创建分桶表的时候必须指定分桶的字段,并且指定要分桶的数量。
    创建分桶表对SQL语句如下:

    create table bigdata17_user_bucket( userid int, username string, fullname string)
    clustered by(userid) into 2 buckets  
    row format delimited fields terminated by ','
    lines terminated by '
    ';
    

    导入数据到bigdata17_user_bucket分桶表中的步骤:

    1. 设置使用分桶属性: set hive.enforce.bucketing = true。
    2. 执行SQL语句
    insert overwrite table bigdata17_user_bucket
     select userid,username ,fullname from bigdata17_user;
    

    执行 hadoop fs -ls /user/hive/warehouse/bigdata17.db/bigdata17_user_bucket命令,会看到bigdata17_user_bucket目录中有两个文件。
    hive table
    其中userid为1和3的数据写入到000001_0文件中,userid为2的数据写入到000000_0的文件中。

    注意:分区和分桶都是按字段来组织数据的存放,分区是相同的字段值存放在一个文件中,而分桶是字段哈希值相同的数据存放在一个文件中。

  • 相关阅读:
    iOS
    iOS
    iOS
    CS页面-Asp.net+Spring.Net.Framework--SNF快速开发平台3.0
    SNF快速开发平台3.0之-界面个性化配置+10种皮肤+7种菜单-Asp.net+MVC4.0+WebAPI+EasyUI+Knockout
    SNF快速开发平台3.0之BS页面展示和九大优点-部分页面显示效果-Asp.net+MVC4.0+WebAPI+EasyUI+Knockout
    MVC通用控件库展示-MVC4.0+WebAPI+EasyUI+Knockout--SNF快速开发平台3.0
    已有打开的与此 Command 相关联的 DataReader,必须首先将它关闭。
    转:ECharts图表组件之简单关系图:如何轻松实现另类站点地图且扩展节点属性实现点击节点页面跳转
    转:zTree树控件入门之checkbox:如何动态设置节点的checkbox选择框启用与禁用状态(chkDisabled)
  • 原文地址:https://www.cnblogs.com/airnew/p/9748751.html
Copyright © 2011-2022 走看看