大数据-hadoop-hdfs

news2024/12/28 2:00:04

Hadoop分布式文件系统(HDFS)是指被设计成适合运行在通用硬件(commodity hardware)上的分布式文件系统(Distributed File System)。它和现有的分布式文件系统有很多共同点。但同时,它和其他的分布式文件系统的区别也是很明显的。HDFS是一个高度容错性的系统,适合部署在廉价的机器上。HDFS能提供高吞吐量的数据访问,非常适合大规模数据集上的应用。HDFS放宽了一部分POSIX约束,来实现流式读取文件系统数据的目的。HDFS在最开始是作为Apache Nutch搜索引擎项目的基础架构而开发的。HDFS是Apache Hadoop Core项目的一部分。

HDFS有着高容错性(fault-tolerant)的特点,并且设计用来部署在低廉的(low-cost)硬件上。而且它提供高吞吐量(high throughput)来访问应用程序的数据,适合那些有着超大数据集(large data set)的应用程序。HDFS放宽了(relax)POSIX的要求(requirements)这样可以实现流的形式访问(streaming access)文件系统中的数据。

•存储模型

•架构设计

•角色功能

•元数据持久化

•安全模式

•副本放置策略

•读写流程

•安全策略


1.存储模型

文件线性按字节切割成块(block),具有offset,id

文件与文件的block大小可以不一样

一个文件除最后一个block,其他block大小一致

block的大小依据硬件的I/O特性调整

block被分散存放在集群的节点中,具有location

Block具有副本(replication),没有主从概念,副本不能出现在同一个节点

副本是满足可靠性和性能的关键

文件上传可以指定block大小和副本数,上传后只能修改副本数

一次写入多次读取,不支持修改

支持追加数据

2.架构设计

HDFS是一个主从(Master/Slaves)架构

由一个NameNode(主)和一些DataNode(从)组成

面向文件包含:文件数据(data)和文件元数据(metadata)

NameNode负责存储和管理文件元数据,并维护了一个层次型的文件目录树

DataNode负责存储文件数据(block块),并提供block的读写

DataNode与NameNode维持心跳,并汇报自己持有的block信息

Client客户端和NameNode交互文件元数据和DataNode交互文件block数据

角色即进程 namenode data node client都是一个JVM进程

3.角色功能

NameNode

•完全基于 内存 存储文件元数据、目录结构、文件block的映射

•需要持久化方案保证数据可靠性

•提供副本放置策略

DataNode

•基于本地磁盘存储block(文件的形式)

•并保存block的(md5)校验和数据保证block的可靠性

•与NameNode保持心跳,汇报block列表状态

4.元数据持久化

数据持久化

日志:记录实时发生的增删改的操作 mkdir /abc

完整性比较好

加载恢复数据: 慢/占空间

镜像、快照、dump、db、序列化

间隔 容易丢失一部分数据

内存全量数据基于某一个时间点做的像磁盘的溢写

HDFS 对于以上两者 同时使用:

日志:EditsLog 优点:体积小 记录少

镜像:FsImage、快照 优点:更快的滚动更新时间点

最近时点的FsImage + 增量的Editslog

现在10点

FI: 9点 +9点到10点的增量的EL

  1. 加载 FI

  1. 加载EL

  1. 内存就得到了关机前的全量数据!

那么:FI 时点是怎么滚动更新的?

由NN 8点溢写 9点溢写。。

NN:第一次开机的时候,只写一次FI 假设8点 到9点的时候EL记录 的是8-9 的日志

只需要将8-9的日志的记录更新到8 点的FI中, FI的数据时点就变成了9点

寻求另外一台机器来做这个事情。

•任何对文件系统元数据产生修改的操作,Namenode都会使用一种称为EditLog的事务日志记录下来

•使用FsImage存储内存所有的元数据状态

•使用本地磁盘保存EditLog和FsImage

•EditLog具有完整性,数据丢失少,但恢复速度慢,并有体积膨胀风险

•FsImage具有恢复速度快,体积与内存数据相当,但不能实时保存,数据丢失多

•NameNode使用了FsImage+EditLog整合的方案:

•滚动将增量的EditLog更新到FsImage,以保证更近时点的FsImage和更小的EditLog体积

5.安全模式

NameNode 存元数据: 文件属性/ 每个块存在哪个dateNode上

在持久化的时候:文件属性会持久化,但是文件的每一个块不会持久化

恢复的时候 NN会丢失块的位置信息

为了避免分布式时代 数据不一致

会等, Data node会和name node建立心跳,汇报块信息(安全模式)

流程:

•HDFS搭建时会格式化,格式化操作会产生一个空的FsImage

•当Namenode启动时,它从硬盘中读取Editlog和FsImage

•将所有Editlog中的事务作用在内存中的FsImage上

•并将这个新版本的FsImage从内存中保存到本地磁盘上

•然后删除旧的Editlog,因为这个旧的Editlog的事务都已经作用在FsImage上了

•Namenode启动后会进入一个称为安全模式的特殊状态。

•处于安全模式的Namenode是不会进行数据块的复制的。

•Namenode从所有的 Datanode接收心跳信号和块状态报告。

•每当Namenode检测确认某个数据块的副本数目达到这个最小值,那么该数据块就会被认为是副本安全(safelyreplicated)的。

•在一定百分比(这个参数可配置)的数据块被Namenode检测确认是安全之后(加上一个额外的30秒等待时间),Namenode将退出安全模式状态。

接下来它会确定还有哪些数据块的副本没有达到指定数目,并将这些数据块复制到其他Datanode上

5.1 HDFS中的SNN

SecondaryNameNode(SNN)

•在非Ha(high avaliable)模式下,SNN一般是独立的节点,周期完成对NN的EditLog向FsImage合并,减少EditLog大小,减少NN启动时间

•根据配置文件设置的时间间隔fs.checkpoint.period 默认3600秒

•根据配置文件设置editslog大小fs.checkpoint.size规定edits文件的最大值默认是64MB

6. Block的副本放置策略

▪第一个副本:放置在上传文件的DN;如果是集群外提交,则随机挑选一台磁盘不太满,CPU不太忙的节点。 (放在本机)

▪第二个副本:放置在于第一个副本不同的机架的节点上。(出机架)

▪第三个副本:与第二个副本相同机架的节点。

▪更多副本:随机节点。

7. HDFS读写流程

7.1 HDFS的写流程

某一时间点 传一个块的:

•Client和NN连接创建文件元数据

•NN判定元数据是否有效

•NN处发副本放置策略,返回一个有序的DN列表

•Client和DN建立Pipeline连接

•Client将块切分成packet(64KB),并使用chunk(512B)+chucksum(4B)填充

•Client将packet放入发送队列dataqueue中,并向第一个DN发送

•第一个DN收到packet后本地保存并发送给第二个DN

•第二个DN收到packet后本地保存并发送给第三个DN

•这一个过程中,上游节点同时发送下一个packet

•生活中类比工厂的流水线:结论:流式其实也是变种的并行计算

•Hdfs使用这种传输方式,副本数对于client是透明的

•当block传输完成,DN们各自向NN汇报,同时client继续传输下一个block

•所以,client的传输和block的汇报也是并行的

7.2 HDFS读流程

•为了降低整体的带宽消耗和读取延时,HDFS会尽量让读取程序读取离它最近的副本。

•如果在读取程序的同一个机架上有一个副本,那么就读取该副本。

•如果一个HDFS集群跨越多个数据中心,那么客户端也将首先读本地数据中心的副本。

•语义:下载一个文件:

•Client和NN交互文件元数据获取fileBlockLocation

•NN会按距离策略排序返回

•Client尝试下载block并校验数据完整性

•语义:下载一个文件其实是获取文件的所有的block元数据,那么子集获取某些block应该成立

•Hdfs支持client给出文件的offset自定义连接哪些block的DN,自定义获取数据

想读哪读哪 而不是必须要从头开始读

•这个是支持计算层的分治、并行计算的核心

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.coloradmin.cn/o/168493.html

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈,一经查实,立即删除!

相关文章

数据结构(3)线段树基础

活动 - AcWing 参考《算法竞赛进阶指南》-lyd 一、概述 1.简述、所需空间 线段树是一种基于分治思想的二叉树结构,用于区间上的信息统计。与树状数组相比,线段树是一种更通用的数据结构。 线段树每个节点代表一个区间。线段树具有唯一根节点&#x…

关于KDDockWidget源码修改和自定义

前言 前面的文章介绍过KDDockWidget的基本使用及示例,文章在这里: KDDockWidgets源码编译及安装 qml dockwidget窗口停靠 QML KDDockWidget 实现 tabwidget效果( 窗口可独立浮动和缩放) 今天主要记录一些在KDDockWidget源码中的…

来自元宇宙的声音:Chord Hero

这一集,我们邀请了 Chord Hero 的联合创始人兼行政总裁 Anthony Chau 来谈谈促使他加入 The Sandbox 元宇宙的原因以及即将在即将到来的游戏赛季推出的第一个项目。 请告诉我们更多关于 Chord Hero 的信息吧。 Chord Hero 通过一系列实体和数字产品让学习音乐变得有…

视图(view)

1、视图:(了解内容) 就是站在不同的角度去看待同一份数据。 视图是MySQL服务器中的一个对象,用于存储查询语句,目的的提高查询语句的使用效率,避免在多处地方重复性开发相同的查询语句。 - 将查询语句交给一…

Transformer学习笔记1

模型分类:GPT类型: auto-regressive(decoder模型,过去时刻的输出也是现在的输入,例如要得到y8还需要知道y1到y7,但不能使用y9,例如用于文本生成任务)GPTGPT2CTRLTransformer XLBERT类…

Docker 容器监控

目录 cAdvisor 安装cAdvisor 使用Prometheus监控cAdvisor cAdvisor暴露的Prometheus指标 容器指标 1. 文档: 2. 指标 硬件指标 1. 文档: 2. 指标: Node Exporter 安装Node Exporter 1. 启动容器,默认端口为9100 2. …

2023免费电脑c盘磁盘数据恢复软件EasyRecovery

无论是台式机还是笔记本电脑,我们都习惯将其划分成多个大小不一的磁盘,有的是用于安装系统,有的则是用于存储文件。今天小编就和大家解答一下关于电脑磁盘的问题,电脑只剩c盘是硬盘坏了吗,电脑突然就剩c盘怎么恢复。想…

【BP靶场portswigger-客户端16】测试WebSockets安全漏洞-3个实验(全)

前言: 介绍: 博主:网络安全领域狂热爱好者(承诺在CSDN永久无偿分享文章)。 殊荣:CSDN网络安全领域优质创作者,2022年双十一业务安全保卫战-某厂第一名,某厂特邀数字业务安全研究员&…

CMMI落地4大工具 助力CMMI3-5级高效落地

CMMI落地4大工具近日正式上线,全面支持CMMI3-5级,助力CMMI高效落地。CoCode旗下的Co-ProjectV3.0智能项目管理平台全新发布:CMMI成熟度自测工具、量化管理工具(组织级过程改进工具和量化项目管理工具)、组织级过程资产…

分享视频剪辑必备的三个素材软件(配音/文案/图片)

hello,大家好,相信现在很多小伙伴都需要制作视频,无论是从事短视频行业,还是单纯想分享生活视频的都需要对视频进行简单的处理吧?有时候会需要介绍视频内容或是给视频增加点配音,来让视频不那么单调&#x…

C++11 解决内存泄露问题的智能指针:shared_ptr、unique_ptr、weak_ptr

我们经常听到内存泄漏,但是对这个抽象的概念一直没有什么理解,比如产生内存泄漏又将如何,我平时写程序从来不考虑这个等等。这篇的目的:第一,给大家实验实验内存泄露带来的问题,让大家直观感受内存泄露。第…

[数据结构基础]链式二叉树及其前序、中序和后序遍历

一. 链式二叉树的结构和实现 1.1 链式二叉树的结构 链式二叉树,即使用链来表示一颗二叉树。链式二叉树的存储又可分为二叉链和三叉链,其中二叉链存储节点数据、指向左子节点的指针和指向右子节点的指针,三叉链相对于二叉链多存储指向父亲节…

一种基于肌电信号运动起点、波峰、终点实时自动检测的方法

一种基于肌电信号运动起点、波峰、终点实时自动检测的方法 (⊙o⊙)…,这篇是我写收费文章的第一篇。咱也尝试下知识付费,哈哈。 先看下效果,在给定理想正弦波的情况下,可以准确识别到正弦波的起点、波峰和终点。机器实拍图如下。 因为我的实际环境没有专利里面那么复杂,所…

Android 蓝牙开发——基础开发(三)

蓝牙开发这部分主要以 APP 端调用功能接口为开始&#xff0c;到 Framework 端的调用流程&#xff0c;最后到调用状态机结束&#xff0c;不涉及蓝牙协议栈的开发分析。 一、BluetoothAdapter 1、APP获取适配器 蓝牙权限 <mainifest><uses-permission android:name&…

3.ESP32-S2/S3 USB 挂载SPI-SD,当作U盘使用,无线U盘

使用的 IDF_4.4 C语言开发 1.ESP32-S2/S3 USB烧录 输出日志 2.ESP32-S2/S3 USB 挂载内部Flash&#xff0c;当作U盘使用&#xff0c;无线U盘 3.ESP32-S2/S3 USB 挂载SPI-SD&#xff0c;当作U盘使用&#xff0c;无线U盘 目录1.打开 usb_msc_wireless_disk 工程 Confinguration2.…

数学建模-数学规划(Matlab)

目录 一、线性规划求解 二、非线性规划问题 三、整数规划&#xff08;包括0-1规划&#xff09; 四、最大最小化模型 五、多目标规划模型 注意&#xff1a;代码文件仅供参考&#xff0c;一定不要直接用于自己的数模论文中国赛对于论文的查重要求非常严格&#xff0c;代码雷同…

微服务Spring Boot 整合 Redis 实现 UV 数据统计

文章目录⛄引言一、HyperLoglog基础用法⛅HyperLoglog 基本语法、命令⚡HyperLoglog 命令完成功能实现二、UV统计 测试百万数据的统计☁️什么是UV统计⚡使用SpringBoot单元测试进行测试百万数据统计⛵小结⛄引言 本文参考黑马 点评项目 在各个项目中&#xff0c;我们都可能需…

DaVinci:限定器 - HSL

调色页面&#xff1a;限定器Color&#xff1a;Qualifier限定器 - HSL Qualifier - HSL根据色相、饱和度和亮度等来选择画面上的对应区域&#xff0c;从而将二级调色与修饰限制在一定的范围。选择范围Selection Range拾取器Picker在检视器画面上按住并拖动&#xff0c;可以选择相…

Linux FHS结构

FHS是Filesystem Hierarchy Standard&#xff08;文件系统层次化标准&#xff09;的缩写&#xff0c;多数Linux版本采用这种文件组织形式&#xff0c;类似于Windows操作系统中c盘的文件目录&#xff0c;FHS采用树形结构组织文件。FHS定义了系统中每个区域的用途、所需要的最小构…

格式化输出

1、golang不同输出语句的区别&#xff1a; 特点PrintPrintlnPrintf输出内容到控制台&#xff08;终端输出&#xff09;SprintSprintlnSprintf输出内容为字符串FprintFprintlnFprintf输出内容到文件特点 输出内容不会换行。 不能格式化字符串。 输出内容换行,。 不能格式化字符…