首页 > 其他分享 >Hive引擎底层初探

Hive引擎底层初探

时间:2024-04-17 10:35:32浏览次数:18  
标签:存储 MapReduce Hive Hadoop 初探 查询 数据 底层

1、什么是Hive

Hive是一个基于Hadoop的数据仓库工具,用于处理和分析大规模结构化数据。Hive提供了类似SQL的查询语言(HiveQL),使得熟悉SQL的用户能够查询数据。Hive将SQL查询转换为MapReduce任务,以在Hadoop集群上执行数据处理和分析。

2、Hive起源

回答这个问题之前,先介绍下Hadoop。Hadoop是专门为离线和大数据分析而设计的分布式基础架构。Hadoop的计算模型是MapReduce,将计算任务分割成多个处理单元,并将其分散到一群家用或服务级别的硬件机器上,从而降低成本。但是直接用MapReduce处理大数据会面临难题:

•MapReduce开发需要具备较高的底层细节知识,开发难度大,学习成本高 •使用MapReduce框架开发,项目周期长,成本高

在此背景下Hive应运而生。Hive是基于Hadoop的一个数据仓库工具,本质是将SQL转换成MapReduce任务进行运算。将结构化的数据文件映射为一张数据库表,并提供简单的sql查询功能,极大降低用户使用难度。

3、Hive架构

3.1 基本组成部分

Hive的架构是一个复杂的系统,通过用户接口、元数据存储、驱动器和Hadoop集群等多个组件的协同工作,实现了对大规模数据的高效存储和查询处理。其架构图如下图所示。

 


 

用户接口模块

这是用户与Hive进行交互的主要方式。Hive提供了多种用户接口,包括CLI(命令行接口)、Client(客户端)、WUI(Web用户界面)以及JDBC/ODBC(允许Java或其他编程语言通过JDBC或ODBC访问Hive)。通过这些接口,用户可以执行HQL(Hive查询语言)语句,进行数据的查询、分析和管理。

BDP平台将页面的SQL转换成SHELL脚本,调用CLI来启动Hive引擎。

 


 

 


 

元数据模块

Hive是将数据文件映射成一张表,元数据模块主要负责描述和管理数据存储、表结构、分区信息等,通常存储在关系型数据库中,如MySQL或Derby。

 


 

 

驱动器(Driver)

驱动器是Hive的核心组件,主要作用是将HiveQL语句转换成一系列的MapReduce(MR)作业。驱动器中包含了解析器、编译器、优化器和执行器等多个子组件。解析器将用户的HQL查询语句转换为抽象语法树(AST),编译器将AST编译成逻辑执行计划,优化器对逻辑计划进行优化,最后执行器将优化后的计划转换成可以运行的物理计划并执行。

 

 


 

Hadoop集群

Hive是建立在Hadoop上的数据仓库基础构架,因此Hadoop集群是Hive架构的重要组成部分。Hive使用Hadoop的分布式文件系统(HDFS)进行数据存储,利用Hadoop的MapReduce框架进行大规模数据的计算和处理。

 

3.2 Hadoop

Hadoop是开源的分布式存储和计算系统,旨在处理大规模数据集。它最初由Apache软件基金会开发,现已成为处理大数据的行业标准之一。Hadoop主要包括以下核心组件:HDFS、MapReduce。

3.2.1 分布式文件系统(HDFS)

HDFS是Hadoop的分布式文件系统,用于存储大规模数据集。它将数据分布存储在集群中的多台服务器上,通过数据冗余存储来提供容错性和高可靠性。

◦高可靠性

HDFS它将文件数据划分为多个数据块,并在集群中的多个节点上进行复制存储。每个数据块默认会有多个(通常是三个)副本存储在不同的节点上。这种冗余存储机制确保了即使某个节点或副本发生故障,数据仍然可以从其他副本中恢复,从而保证了数据的高可靠性。

◦HDFS架构

HDFS采用了主从架构,包括一个NameNode和多个DataNode。NameNode负责管理文件系统的命名空间和元数据信息,而DataNode负责存储实际的数据块。

◦读取文件的过程: 1.客户端向NameNode请求获取文件,并对请求进行检查。 2.如果请求检查通过,NameNode将查询元数据,向客户端返回文件所在的各个Block的DN地址。 3.客户端拿到DN列表之后,按照Block,根据负载规则请求一台服务器,建立通道读取数据。 4.DN接收到请求后,向客户端传输Block内容。 5.获取到的内容,存入本地缓存,然后写入到输出目标中。

 


 

3.2.2 分布式计算框架(MapReduce)

MapReduce是Hadoop的分布式计算框架,用于在大规模数据集上执行并行计算任务。它将计算任务分解为多个独立的子任务,然后在集群中的多台计算节点上并行执行这些子任务。MapReduce包括Map阶段和Reduce阶段 ,2个阶段。

◦Map阶段将原始数据分解为更小的数据单元,这些单元可以被并行处理,且彼此之间没有太多依赖。 ◦Reduce阶段则对Map阶段生成的中间结果进行汇总,以得到最终的处理结果。

 


 

4、Hive工作流程

Hive是一个建立在Hadoop之上的数据仓库系统,它提供了类似于SQL的查询语言(HiveQL),使用户可以在大规模数据集上执行查询和分析操作。下面是Hive的工作流程:

1.解析HiveSQL: ◦当用户提交一个HiveSQL查询时,Hive的解析器首先会解析这个查询,将其转换成一个抽象语法树(AST)。 ◦解析器会检查SQL语法的正确性,并将SQL语句的各个部分(如SELECT、FROM、WHERE等)转换为相应的内部表示。 2.语义分析: ◦语义分析阶段会检查查询的语义正确性,确保所有引用的表、列和函数都存在且有效。 ◦在这个阶段,Hive还会获取表的元数据,如列的数据类型、表的分区信息等,为后续的计划生成做准备。 3.生成逻辑执行计划: ◦接下来,Hive会根据解析和语义分析的结果,生成一个逻辑执行计划。这个计划描述了查询的执行步骤,但不涉及具体的物理操作。 ◦逻辑计划通常包括一系列的操作,如扫描表、过滤数据、聚合数据等。 4.逻辑计划优化: ◦在生成逻辑计划后,Hive会对其进行优化,以提高查询的执行效率。 ◦优化可能包括重写查询、消除冗余操作、选择更有效的连接策略等。 5.生成物理执行计划: ◦优化后的逻辑计划会被转换为物理执行计划。物理计划描述了如何在Hadoop集群上实际执行查询。 ◦在这个阶段,Hive会决定将哪些操作映射到MapReduce任务上,以及如何在集群中分配这些任务。 6.执行MapReduce任务: ◦根据物理执行计划,Hive会启动MapReduce任务来执行查询。任务读取的数据来自HDFS。 ◦Map阶段通常负责读取数据并进行一些基本的处理,如过滤和转换。 ◦Reduce阶段则负责聚合数据并生成最终结果。 7.返回结果: ◦当所有MapReduce任务完成后,Hive会收集并整理结果,然后将其返回给用户。

 

标签:存储,MapReduce,Hive,Hadoop,初探,查询,数据,底层
From: https://www.cnblogs.com/Jcloud/p/18139993

相关文章

  • hive on spark内存模型
    内容介绍hiveonspark的调优,那必然涉及到这一系列框架的内存模型。本章就是来讲一下这些框架的内存模型。hiveonspark的任务,从开始到结束。总共涉及了3个框架。分别是:yarn、hive、spark其中,hive只是一个客户端的角色。就不涉及任务运行时的内存。所以这里主要讲的yarn和spa......
  • hive窗口分析函数使用详解系列二之分组排序窗口函数
    1.综述我们讨论面试中各大厂的SQL算法面试题,往往核心考点就在于窗口函数,所以掌握好了窗口函数,面对SQL算法面试往往事半功倍。已更新第一类聚合函数类,点击这里阅读hive窗口函数聚合函数类本节介绍Hive聚合函数中的第二类聚合函数:分组排序窗口函数。这些函数的用法不仅仅适用于......
  • CH582/CH592_EVT中RF_Device(主机)例程详解_底层自动跳频管理_支持一对七通讯
    目标程序路径: 与RF_Device程序相比,RF_Host主要讲解三个地方,其他接口与RF_Device一致,查看这篇博客:CH582/CH592_EVT中RF_Device(从机)例程详解_底层自动跳频管理_支持一对七通讯1、Host配对绑定逻辑:程序中默认逻辑为上电后前三秒钟允许配对绑定新设备,超过三秒钟则从flash中取出......
  • Redis Pipelining 底层原理分析及实践
    作者:vivo互联网服务器团队-WangFeiRedis是一种基于客户端-服务端模型以及请求/响应的TCP服务。在遇到批处理命令执行时,Redis提供了Pipelining(管道)来提升批处理性能。本文结合实践分析了SpringBoot框架下Redis的Lettuce客户端和Redisson客户端对Pipeline特性的支持原理,并针......
  • 蓝桥杯单片机基于西风模板超声波底层
    超声波是外设需要重新自己编写c文件和h文件在c文件中需要编写两个函数一个是波的初始化一个是方波的读取voidWave_Init(){unsignedchari;for(i=0;i<8;i++){TX=1;发送信号Delay(12)us哦Tx=0在延时12us}这样波的初始化就好了}unsignedcharWave_Read(){unsig......
  • Android Compose 入门,深入底层源码分析
    AndroidCompose入门,深入底层源码分析我是跟着AS官网学习的,但是官方的教程写的不是很详细.官网链接首先创建一个Compose项目,目录结构是这样:ui->theme->->Color.kt->->Theme.kt->->Type.ktMainActivity.kt通过阅读源码,发现实际上还少了一个Shapes.kt,我手动......
  • IOS开发Archives打包后构建版本发布到TestFlight全流程
    前言:构建版本之前一定要先配置好项目icons,不然会报错。1.选择需要构建的包之后,点击右侧的DistributeApp按钮:2.Selectamethodofdistribution界面,选择AppStoreConnect(要发布到TestFlight需要选这个)3.Selectadestination——选择Upload(如果选择Export,则需要自己用......
  • Hive - [02] Local模式的安装部署
     1、将hive的包解压到/opt/module目录下2、在conf/hive-env.sh中配置hadoop的路径3、依次启动Zookeeper、HDFS相关服务zkCluster.sh、jpsall.sh均为自行配置的shell脚本jpsall.sh:foripin`cat/etc/hosts|grepctos|awk'{print$2}'`;doecho----------$ip----......
  • Python异步HTTP客户端和服务器功能的底层库之httpcore使用详解
    概要httpcore库是一个提供异步HTTP客户端和服务器功能的底层库,它是许多高级HTTP客户端库的基础,如httpx。httpcore旨在提供一个快速、稳定且易于使用的HTTP组件。安装通过pip可以轻松安装httpcore:pip install httpcore特性异步支持:原生支持异步操作,提高I/O效率。......
  • 手写Spring底层机制
    手写Spring底层机制IOC容器//定义BeanDefinitionMap存放beanDefinitionprivateConcurrentHashMap<String,BeanDefinition>beanDefinitionMap=newConcurrentHashMap<>();//定义singletonObjects存放单例privateConcurrentHashMap<S......