zoukankan      html  css  js  c++  java
  • Hive相关

    一、Hive中追加导入数据的4种方式是什么

    1、从本地导入: 
    load data local inpath ‘/home/1.txt’ (overwrite)into table student;
    2、从Hdfs导入: 
    load data inpath ‘/user/hive/warehouse/1.txt’ (overwrite)into table student;
    3、查询导入: 
    create table student1 as select * from student;(也可以具体查询某项数据)
    4、查询结果导入:
    insert (overwrite)into table staff select * from track_log;

    将 text.txt 文件放入 hive 中 test 表‘2016-10-10’ 分区的语句,test 的分区字段是 l_date 

    load data local inpath '/your/path/test.txt' overwrite into table test partition(1_date='2016-10-10')

    二、Hive导出数据

    1、用insert overwrite导出方式
    导出到本地:

    insert overwrite local directory ‘/home/robot/1/2’ rom format delimited fields terminated by ‘	’ select * from staff;(递归创建目录)

    导出到HDFS

    insert overwrite directory ‘/user/hive/1/2’ rom format delimited fields terminated by ‘	’ select * from staff;

    2、Bash shell覆盖追加导出

    3、Sqoop把hive数据导出到外部

    三、数据倾斜的原因及解决措施

    原因:

    1、key分布不均匀

    2、业务数据本身的特性

    3、建表时考虑不周

    4、某些SQL语句本身就有数据倾斜

    措施:

    1、参数调节

    hive设置hive.map.aggr=true和hive.groupby.skewindata=true

    有数据倾斜的时候进行负载均衡,当选项设定为true,生成的查询计划会有两个MR Job。第一个MR Job中,Map的输出结果集合会随机分布到Reduce中,每个Reduce做部分聚合操作,并输出结果,这样处理的结果是相同Group By Key有可能被分发到不同的Reduce中,从而达到负载均衡的目的;第二个MR Job在根据预处理的数据结果按照 Group By Key 分布到Reduce中(这个过程可以保证相同的 Group By Key 被分布到同一个Reduce中),最后完成最终的聚合操作。

    2、SQL语句调节

    • 选用join key 分布最均匀的表作为驱动表。做好列裁剪和filter操作,以达到两表join的时候,数据量相对变小的效果。
    • 大小表Join: 使用map join让小的维度表(1000条以下的记录条数)先进内存。在Map端完成Reduce。
    • 大表Join大表:把空值的Key变成一个字符串加上一个随机数,把倾斜的数据分到不同的reduce上,由于null值关联不上,处理后并不影响最终的结果。
    • count distinct大量相同特殊值:count distinct时,将值为空的情况单独处理,如果是计算count distinct,可以不用处理,直接过滤,在做后结果中加1。如果还有其他计算,需要进行group by,可以先将值为空的记录单独处理,再和其他计算结果进行union.

    四、Hive和SQL比较

    Hive是基于Hadoop的一个数据仓库工具,可以将结构化的数据文件映射为一张数据库表,并提供完整的sql查询功能,可以将SQL语句转换成MapReduce任务进行运行。它的优点就是学习成本低,可以通过类SQL语句快速实现简单的MapReduce统计,不必开发专门的MapReduce应用,十分适合数据仓库的统计分析。缺点:不支持实时数据查询。

    五、内部表和外部表的区别

    1、创建表时:创建内部表时,会将数据移动到数据仓库指向的路径;若创建外部表,仅记录数据所在的路径, 不对数据的位置做任何改变。
    2、删除表时:在删除表的时候,内部表的元数据和数据会被一起删除, 而外部表只删除元数据,不删除数据。这样外部表相对来说更加安全些,数据组织也更加灵活,方便共享源数据。

    六、分区和分桶

    分区
    指按照数据表的某列或某些列分为多个区,区从形式上可以理解为文件夹。比如我们要收集某个大型网站的日志数据,一个网站每天的日志数据存在同一张表上,由于每天会生成大量的日志,导致数据表的内容巨大,在查询时进行全表扫描耗费的资源非常多。这个情况下,我们可以按照日期对数据表进行分区,不同日期的数据存放在不同的分区,在查询时只要指定分区字段的值就可以直接从该分区查找
    分桶
    分桶是相对分区进行更细粒度的划分。分桶将整个数据内容安装某列属性值得hash值进行区分,如要按照name属性分为3个桶,就是对name属性值的hash值对3取摸,按照取模结果对数据分桶。如取模结果为0的数据记录存放到一个文件,取模为1的数据存放到一个文件,取模为2的数据存放到一个文件

    七、Hive中的排序关键字

    sort by :不是全局排序,其在数据进入reducer前完成排序

    order by :会对输入做全局排序,因此只有一个reducer(多个reducer无法保证全局有序).只有一个reducer,会导致当输入规模较大时,需要较长的计算时间。

    cluster by : 当distribute by 和sort by的字段相同时,等同于cluster by.可以看做特殊的distribute + sort

    distribute by :按照指定的字段对数据进行划分输出到不同的reduce中

  • 相关阅读:
    图解C/C++多级指针与多维数组
    排序---选择排序
    排序---插入排序
    排序---希尔排序
    Merge Two Sorted Lists
    Remove Nth Node From End of List
    如何阅读Django文档?
    机器学习 第一章 绪论 笔记
    python工程实践·笔记
    Python后端开发面经
  • 原文地址:https://www.cnblogs.com/kingshine007/p/11435503.html
Copyright © 2011-2022 走看看