Day1 - Hive基础知识

这篇具有很好参考价值的文章主要介绍了Day1 - Hive基础知识。希望对大家有所帮助。如果存在错误或未考虑完全的地方,请大家不吝赐教,您也可以点击"举报违法"按钮提交疑问。

Hive

简介

概述

  1. Hive是由Facobook开发的后来贡献给了Apache的一套用于进行数据仓库管理的工具,使用类SQL语言来对分布式文件系统中的PB级别的数据来进行读写、管理以及分析
  2. Hive基于Hadoop来使用的,底层的默认计算引擎使用的是MapReduce。Hive利用类SQL(HQL,Hive Query Language)语言来操作数据,但是底层是将SQL转化为MapReduce来执行(效率低下),也因此,Hive更适合于处理离线分析场景
  3. Hive可以屏蔽掉不同语言之间的差异性,降低了大数据的入门门槛
  4. Hive的支持的计算引擎:MapReduce、Tez、Spark。底层默认使用的是MapReduce,但是效率最高的是Spark
  5. 在Hive中,库名、表名、字段名、字段类型、分区、分桶等信息属于元数据,是存储在数据库中,默认支持的是Derby。但是Derby本身是一个单连接的数据库(只允许一个客户端),所以会将Hive的元数据库替换为MySQL。注意:Hive的元数据是存储在数据库的,Hive的数据是放在HDFS上!

版本

  1. 到目前为止,Hive一共有4个版本:Hive1.X和Hive4.X
  2. Hive4.X一共有3个小版本(alpha1、alpha2、beta1),目前都是测试版
  3. 目前,在市面上,Hive1.x到Hive3.x都在使用,其中Hive1.x逐渐被抛弃,现在市面上使用较多的是Hive2.x和Hive3.x
  4. Hive3.x需要基于Hadoop3.x使用,Hive2.x需要基于Hadoop2.x使用

基本语法

注意问题

  1. Hive中,如果不指定,默认只有一个库default
  2. 在Hive中,每一个database对应了HDFS上的一个目录。默认情况下,database是放在HDFS的/user/hive/warehouse
  3. 在Hive中,没有主键的概念,也不支持主键
  4. Hive中的每一个表也对应了HDFS上的一个目录
  5. Hive中建表的时候需要指定字段之间的间隔符号,表一旦建好,字段之间的间隔符号就不能变化!
  6. Hive的数据默认支持insert和select,默认不支持delete和update。如果需要支持delete和update操作,那么在建表的时候,需要指定Hive数据在HDFS上的文件存储类型必须是orcparquet格式

库操作

  1. 查看所有的库

    show databases;
    
  2. 建库

    create database demo;
    
  3. 删除库。要求库必须是空的

    drop database demo;
    
  4. 建库的时候指定库的存储位置

    create database demo location '/demo.db';
    
  5. 利用正则表达式过滤符合要求的库

    show databases like 'd*';
    
  6. 建库的时候,判断库是否存在。如果不存在,那么建库

    create database if not exists demo;
    
  7. 强制删除库

    drop database demo cascade;
    
  8. 使用库

    use demo;
    
  9. 建库的时候还给库指定属性

    create database demo2 with dbproperties('create_time'='2024-03-26');
    
  10. 描述库

    desc database demo2;
    
  11. 描述库的详细信息

    desc database extended demo2;
    
  12. 修改库的属性

    alter database demo2 set dbproperties('create_time'='024-03-27');
    

表及数据操作

  1. 创建表

    create table person ( id int, name string, age int);
    
  2. 插入数据

    insert into table person values(1, 'Amy', 15);
    

    转化为MapReduce执行

  3. 查询数据

    select * from person;
    
  4. 加载数据 - 实际上就是将文件上传到HDFS上,加载速度和文件的上传速度相关

    load data local inpath '/opt/hive_data/person' into table person;
    -- load data 加载数据
    -- local 本地
    -- inpath 输入路径
    
  5. 删除表

    drop table person;
    
  6. 建立person表,指定字段之间的间隔符号是空格

    create table person ( id int, name string, age int) row format delimited fields terminated by ' '; 
    -- row format 对数据进行按行的处理
    -- delimited 对什么数据进行拆分
    -- fields 字段、属性
    -- terminated by ' ' 用什么拆分
    
  7. 查看所有的表

    show tables;
    
  8. 描述表

    desc person
    
  9. 创建p2表,p2的表结构和person一样

    create table p2 like person;
    
  10. 如果p3表不存在,那么创建p3表,表结构和person一样

    create table if not exists p3 like person;
    
  11. 创建p4表,表结构以及数据都和person一样(复制person表)

    -- 将person的数据全部查询出来,根据查询数据的结构来建立p4表并放入数据
    create table p4 as select * from person;
    select * from p4;
    
  12. 将person表中age>=18的数据查询出来,放入p2表中

    insert into table p2 select * from person where age >= 18;
    

    注意insert into表示向表中追加数据,insert overwrite先将表中的数据清空掉,然后再覆盖写入

  13. 从person表中查询数据,将id<5的数据覆盖到p2表中,将age<18的数据写入到p3表中

    from person
     insert overwrite table p2 select * where id < 5
     insert into table p3 select * where age < 18;
    
  14. 将person表中id>5的数据查询出来放到HDFS的/person目录下,字段之间用,间隔

    insert overwrite directory '/person' row format delimited fields terminated by ',' select * from person where id > 5;
    

    如果是将数据写到Hive之外的地方,此时只能使用insert overwrite,所以要求输出路径必须为空。如果输出路径不为空,那么会将输出路径下的所有文件给清空!!!

  15. Hive除了支持将结果写到HDFS上,还支持写到本地磁盘上

    insert overwrite local directory '/opt/hive_demo' row format delimited fields terminated by '\t' select * from person where age >= 18;
    

    同样,要求输出路径必须为空!!!

  16. 将person表重命名为p1

    alter table person rename to p1;
    
  17. 将p1表的id字段改为pid,类型改为string

    alter table p1 change column id pid string;
    
  18. 在p1表中新增字段:gender,类型是string

    alter table p1 add columns(gender string);
    

表结构

内部表和外部表

  1. 在Hive中,所有的表分为内部表(又叫管理表,Managed Table)和外部表(External Table)

  2. 一般而言,在Hive中,手动建表手动添加数据的表,大部分是内部表;在Hive中,建表管理HDFS上已经存在的数据,这个表称之为外部表

  3. 可以通过

    desc extended p1;
    -- 或者
    desc formatted p1;
    

    如果是内部表,那么tableType的值MANAGED_TABLE;如果是外部表,那么tableType的值EXTERNAL_TABLE

  4. 建立外部表

    create external table flows (
        phone string,
        city string,
        name string,
        upFlow int,
        downFlow int
    ) row format delimited fields terminated by ' '
     location '/flow';
    
  5. 查询数据

    -- tablesample,抽样函数
    select * from flows tablesample(5 rows);
    
  6. 删除内部表,那么对应的元数据和HDFS上的目录都会删除;删除外部表,那么只删除元数据但是不删除HDFS上的目录

  7. 在实际过程中,项目前期使用外部表,中后期使用内部表

  8. 内部表转化为外部表

    alter table p3 set tblproperties ( 'EXTERNAL' = 'true');
    
  9. 外部表转化为内部表

    alter table p3 set tblproperties ( 'EXTERNAL' = 'false');
    

分区表

  1. 分区表的最常见的作用也是对数据进行分类

  2. 案例

    1. 原始数据

      -- wei
      1 荀彧
      2 荀攸
      3 贾诩
      4 郭嘉
      -- shu
      1 孙乾
      2 简雍
      3 糜竺
      4 庞统
      -- wu
      1 陆逊
      2 张昭
      3 鲁肃
      4 周瑜
      
    2. 在Hive中建表,管理数据,同时区分数据对应的国家

      create table heros (
          id int, -- 编号
          name string -- 姓名
      ) partitioned by (country string)
       row format delimited fields terminated by ' ';
      
    3. 查看表

      desc heros;
      
    4. 将数据加载到表中。当向分区表中加载数据的时候,如果没有指定分区,那么会将数据放入默认分区__HIVE_DEFAULT_PARTITION__

      load data local inpath '/opt/hive_data/wei' into table heros partition(country = 'wei');
      load data local inpath '/opt/hive_data/shu' into table heros partition(country = 'shu');
      load data local inpath '/opt/hive_data/wu' into table heros partition(country = 'wu');
      
  3. 在Hive中,每一个分区对应HDFS上一个单独的目录!!!

  4. 在分区表中,当查询数据的时候以分区作为查询条件,可以提高查询效率;如果进行跨分区查询,那么此时效率会降低

  5. 手动在HDFS上创建的目录,默认不会自动加载到Hive的元数据中

  6. 手动建立分区

    # 在HDFS上建立目录,上传文件
    hadoop fs -mkdir /user/hive/warehouse/demo.db/heros/country=qun
    hadoop fs -put qun /user/hive/warehouse/demo.db/heros/country=qun
    

    在Hive中手动添加分区

    alter table heros add partition(country = 'qun') location '/user/hive/warehouse/demo.db/heros/country=qun';
    -- 或者 修复分区 - 有可能会修复失败,如果修复失败,那么此时只能手动add
    msck repair table heros;
    
  7. 修改分区名

    alter table heros partition(country = 'qun') rename to partition(country = 'other');
    
  8. 删除分区

    alter table heros drop partition(country = '__HIVE_DEFAULT_PARTITION__');
    
  9. 需要注意的是,在Hive中,分区字段在原始数据中是不存在的,而是在加载数据的时候手动指定,所以分区实际上可以认为是数据的"伪列"。如果原始数据中包含了分区字段,那么此时就需要进行动态分区

  10. 动态分区

    1. 原始数据

      1 other 吕布
      2 wei 甘宁
      3 shu 马岱
      4 wei 王凌
      5 shu 糜芳
      6 shu 魏延
      7 other 刘璋
      8 wei 丁仪
      9 wu 周平
      10 shu 马忠
      
    2. 建立临时表

      create table heros_tmp (
          hid int,
          h_country string,
          h_name string
      ) row format delimited fields terminated by ' ';
      
    3. 加载数据

      load data local inpath '/opt/hive_data/heros' into table heros_tmp;
      -- 测试
      select * from heros_tmp tablesample(5 rows);
      
    4. 动态分区默认是不开启

      -- 只对本次session有效,如果退出Hive重新进入,那么依然是严格模式
      set hive.exec.dynamic.partition.mode = nonstrict;
      
    5. 将未分区表中的数据插入到分区表中 - 动态分区文章来源地址https://www.toymoban.com/news/detail-861532.html

      insert into table heros partition(country) select hid, h_name, h_country from heros_tmp distribute by h_country;
      

到了这里,关于Day1 - Hive基础知识的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处: 如若内容造成侵权/违法违规/事实不符,请点击违法举报进行投诉反馈,一经查实,立即删除!

领支付宝红包 赞助服务器费用

相关文章

  • Hive基础知识(十):Hive导入数据的五种方式

    1)语法 (1)load data:表示加载数据 (2)local:表示从本地加载数据到 hive 表;否则从 HDFS 加载数据到 hive 表 (3)inpath:表示加载数据的路径 (4)overwrite:表示覆盖表中已有数据,否则表示追加 (5)into table:表示加载到哪张表 (6)student:表示具体的表 (7)partition:表示上传到

    2024年01月18日
    浏览(54)
  • Hive基础知识(十六):Hive-SQL分区表使用与优化

    分区表实际上就是对应一个 HDFS 文件系统上的独立的文件夹,该文件夹下是该分区所有的数据文件。 Hive 中的分区就是分目录 ,把一个大的数据集根据业务需要分割成小的数据集。在查询时通过 WHERE 子句中的表达式选择查询所需要的指定的分区,这样的 查询效率会提高很多

    2024年01月18日
    浏览(39)
  • HBase基础知识(六):HBase 对接 Hive

    1.Hive (1) 数据仓库 Hive 的本质其实就相当于将 HDFS 中已经存储的文件在 Mysql 中做了一个双射关系,以 方便使用 HQL 去管理查询。 (2) 用于数据分析、清洗 Hive 适用于离线的数据分析和清洗,延迟较高。 (3) 基于 HDFS、MapReduce Hive 存储的数据依旧在 DataNode 上,编写的 HQL 语句终

    2024年02月04日
    浏览(44)
  • Hive报错org.apache.hadoop.hive.ql.exec.mr.MapredLocalTask

    报错Error while compiling statement: FAILED: Execution Error, return code 1 from org.apache.hadoop.hive.ql.exec.mr.MapredLocalTask 执行Hive两个表JOIN时出现如上错误 报错原因: 执行的join是大表和小表进性join,而Hive默认开启了MapJoin,即:hive.auto.convert.join=true; 但集群机器内存不够,导致出错。 Map Join

    2024年02月12日
    浏览(62)
  • hive 报错return code 40000 from org.apache.hadoop.hive.ql.exec.MoveTask解决思路

    参考学习 https://github.com/apache/hive/blob/2b57dd27ad61e552f93817ac69313066af6562d9/ql/src/java/org/apache/hadoop/hive/ql/ErrorMsg.java#L47 为啥学习error code 开发过程中遇到以下错误,大家觉得应该怎么办?从哪方面入手呢? 1.百度? 2.源码查看报错地方 3.忽略(这个错是偶发的) 但是这个错是hive的错,

    2024年02月03日
    浏览(62)
  • 【Hive-Exception】return code 1 from org.apache.hadoop.hive.ql.exec.DDLTaskHIVE

    解决方案: 如果不能设置值,会报错。 Error: Error while processing statement: Cannot modify hive.msck.path.validation at runtime. It is not in list of params that are allowed to be modified at runtime (state=42000,code=1) 在hive-site中添加内容:

    2024年02月09日
    浏览(41)
  • hive报错:FAILED: Execution Error, return code 1 from org.apache.hadoop.hive.ql.exec.DDLTask.

    使用hive创建表的时候报错:FAILED: Execution Error, return code 1 from org.apache.hadoop.hive.ql.exec.DDLTask. MetaException(message:Got exception: java.net.ConnectException Call From node01/192.168.126.100 to node01:9000 failed on connection exception: java.net.ConnectException: Connection refused; For more details see:  http://wiki.apache.org/ha

    2024年02月09日
    浏览(48)
  • hive报错——FAILED: Execution Error, return code 1 from org.apache.hadoop.hive.ql.exec.StatsTask

    今天向分区表插入数据 insert into table--------的时候 执行完报错了:FAILED: Execution Error, return code 1 from org.apache.hadoop.hive.ql.exec.StatsTask 重启了电脑也没用, 修改了yarn-site.xml和mapred-site.xml增加yarn和mapreduce可用内存都没用 然后同学让我加了一句话 set set hive.stats.column.autogather=false  

    2024年02月08日
    浏览(42)
  • Hive表字段类型转换错误解决:Execution Error, return code 1 from org.apache.hadoop.hive.ql.exec.DDLTask.

    假设某有数据的Hive表temp_table的字段状况如下,需要将A字段由string类型转为int类型: 字段名称 字段类型 是否为分区字段 A string 否 B int 否 C bigint 否 D string 是 在Hdfs数据库中,该表的数据是以Parquet文件格式存储的,包含多个分区。 原本在该表中的字段A的类型为int 。然而笔者

    2024年02月02日
    浏览(81)
  • [hive]return code -101 from org.apache.hadoop.hive.ql.exec.mr.MapRedTask. GC overhead limit exceeded

    [2022-11-10 10:21:31] [08S01][-101] Error while processing statement: FAILED: Execution Error, return code -101 from org.apache.hadoop.hive.ql.exec.mr.MapRedTask. GC overhead limit exceeded 一般map读取一个片的数据不会内存不够,所以: 1、调大reduce个数 2、group by 数据倾斜 3、使用大的队列

    2024年02月12日
    浏览(35)

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

请作者喝杯咖啡吧~博客赞助

支付宝扫一扫领取红包,优惠每天领

二维码1

领取红包

二维码2

领红包