Hadoop学习----HDFS

news2025/1/19 17:22:48

文件系统

  • 文件系统:是一种存储和组织数据的方法,实现数据的存储、分级组织、访问和获取等操作,使得用户对文件访问和查找变得容易。
  • 文件系统使用树形目录的抽象逻辑概念代替了硬盘等物理设备使用数据块的概念,用户不必关心数据底层存在硬盘哪里,只需要记住这个文件所属目录和文件名即可。
  • 文件系统通常使用硬盘和光盘这样的存储设备,并维护文件在设备中的物理位置

传统常见的文件系统,更多的指的是单机文件系统,也就是底层不会横跨多台机器实现,比如windows操作系统的文件系统,Linux系统的文件系统等
这些文件系统特征:
1、带有抽象的目录树形结构,树都是从根目录开始向下蔓延
2、树中节点分为两类:目录和文件
3、从根目录开始,节点路径具有唯一性

数据和元数据:

  • 数据:指的是内容本身,比如文件、视频、图片等,这些数据底层最终存储在磁盘等存储介质上的,用户无需关心,只需要基于目录树进行增删改查即可,实际针对数据的操作由文件系统完成。
  • 元数据:称之为解释性数据,文件系统的元数据一般指,文件大小,最后修改时间,存储位置,权限等。

大数据时代,面对海量数据,传统文件系统问题。
传统存储硬件通用性差,设备投资加上后期维护、升级扩容成本非常高。
传统文件系统无法支撑高效率的计算分析,传统存储方式意味着数据,存储是存储,计算是计算,当需要处理数据时,把数据移动过来(移动到内存,内存能容下多大数据),数据和程序属于不用的技术厂商实现,无法有机统一整合在一起。
单节点IO性能瓶颈无法逾越,难以支撑海量数据的高并发高吞吐场景。
可扩展性差,无法实现快速部署和弹性扩展,动态扩容,缩容成本高,技术实现难度大。

分布式存储的优点

分布式存储功能
问题:数据量大,单机存储遇到瓶颈
解决:
单机纵向扩展:磁盘不够加磁盘,有上限瓶颈限制
多机横向扩展:机器不够加机器,理论上无线扩展

元数据记录功能
文件分布在不同机器上不利于寻找
元数据记录下文件及其存储位置信息,快速定位文件位置
Namenode管理的元数据具有两种类型:
1、文件自身属性信息:文件名称、权限、修改时间、文件大小、复制因子
2、文件快位置映射信息:记录文件快和DataNode之间的映射信息,即哪个快位于哪个节点上

文件分块存储
问题:文件过大导致单机存不下,上传下载效率低
解决:文件分块存储在不同机器,针对 块 并行操作提高效率,元数据进行详细描述。
块大小默认是128M,不足128M则本身就是一块,块的大小可以通过配置参数来规定,参数位于hdfs-default.xml中dfs.blocksize

副本机制作用:
问题:硬件故障,数据丢失
解决:不同机器设置备份,冗余存储,保障数据安全。升级元数据描述,描述冗余数据
文件的所有block都会有副本,副本系数可以在文件创建的时候指定,也可以在之后通过命令改变。副本参数由dfs.replication控制,默认值是3,也就是会额外再复制2分,连同本身共3份副本。

HDFS

HDFS(Hadoop Distributed File System),Hadoop分布式文件系统
是Apache Hadoop核心组件之一,作为大数据生态圈最底层的分布式存储服务而存在,也可以说大数据首先要解决的问题就是海量数据的存储问题。
在这里插入图片描述
HDFS简介

  • HDFS主要是解决大数据如何存储问题,分布式意味着HDFS是横跨在多台机器上的存储系统。
  • HDFS是一种能够在普通硬件上运行的分布式文件系统,它的高度容错的,适应于具有大数据集的应用程序,它非常适用于存储大型数据
  • HDFS使用多台计算机存储文件,并且提供统一的访问接口,像是访问一个普通文件系统一样使用分布式文件系统
    在这里插入图片描述
HDFS shell命令操作

固定前缀:hadoop fs
HDFS Shell CLI支持操作多种文件系统,具体操作的是什么文件系统取决于命令中文件路径URL中的前缀协议
如果没有指定前缀,则会读取环境变量中的fs.defaultFS属性,以该属性作为默认文件系统
就是core-site.xml中的

<property>
    <name>fs.defaultFS</name>
    <value>hdfs://node1:8020</value>
</property>
hadoop fs -ls file:///  #操作本地文件系统
hadoop fs -ls hdfs://node1:8020/ #操作HDFS分布式文件系统

HDFS文件系统的操作命令很多和Linux类似,因此学习成本相对较低。可以通过hadoop fs -help命令查看每个命令的详细用法

hadoop fs -mkdir [-p] <path>
# path为带创建的目录 -p选项的行为是创建多级目录时

hadoop fs -ls [-h][-R]  [<path>]
# path 指定目录路径  -h 人性化显示文件size  -R 递归查看指定目录及其子目录

hadoop fs -put [-f][-p] <localsrc> <dst>
# -f 覆盖目标文件(已存在下)   -p 保留访问和修改时间,所有权和权限
# localsrc 本地文件系统(客户端所在的系统)      dst 目标文件系统

hadoop fs -cat <src>
# 读取指定文件全部内容,显示在标准输出控制台。对于大文件的内容读取,慎重

hadoop fs -get [-f][-p] <src> <localsrc>
# 下载文件到本地文件系统,localsrc是必须目录
# -f 覆盖目标文件(已存在下)  -p 保留访问和修改时间,所有权和权限
hadoop fs -get  /test/1.txt  ./2.txt   # 下载并改名 

hadoop fs -appendToFile <localsrc>  <dst>
# 将所有给定本地文件的内容追加到给定dst文件中
# dst如果文件不存在,将创建该文件,如果localsrc为-,则输入为从标准输入中读取
hadoop fs -appendToFile  ./1.txt ./2.txt ./3.txt  /test.txt

HDFS 集群和角色

主角色 NameNode,是Hadoop分布式文件系统的核心,架构中的主角色。维护和管理文件系统元数据,包括名称空间目录树结构,文件和块的位置信息,访问权限等信息。

从角色 DataNode,Hadoop的HDFS集群中的从角色,负责具体的数据块存储
DataNode的数量决定了HDFS集群的整体数据存储能力,通过和NameNode配合维护数据块

主角色辅助角色 secondaryNameNode,充当NameNode辅助节点,但不能代替NameNode
主要是帮助主角色进行元数据文件的合并动作,可以通俗理解为主角色的秘书

HDFS 写数据流程(上传文件)

核心概念–Pipeline管道
Pipeline中文翻译为管道,这是HDFS在上传文件写数据过程中采用的一种数据传输方式
客户端将数据写入第一个数据节点,第一个数据节点保存数据之后再将块复制到第二个数据节点,后者保存后将其复制到第三个数据节点。
在这里插入图片描述
核心概念–ACK应答响应
ACK即是确认字符,再数据通信中,接收方发给发送方的一种传输类控制字符,表示发来的数据已确认接收无误
再HDFS pipeline 管道传输数据的过程中,传输的反方向会进行ACK校验,确保数据传输安全。
ACK校验是两两之间的校验
在这里插入图片描述
核心概念–默认3副本存储策略
默认副本存储策略是由Block Placement Policy Default指定
第一块副本:优先客户端本地(如果存储空间允许),否则随机
第二块副本:不同于第一块副本的不同机架
第三块副本:第二块副本相同机架的不同机器

客户端上传文件的具体流程
1、HDFS客户端创建对象实例DistributedFileSystem,该对象中封装了与HDFS文件系统操作的相关方法
2、调用DistributedFileSystem对象的create()方法,通过RPC请求NameNode创建文件
NameNode执行各种检查判断:目标文件是否存在、父目录是否存在,客户端是否具有创建该文件的权限,检查
通过,NameNode就会为本次请求记录下一条记录,返回FSDataOutputStream输出流对象给客户端用于写数据
3、客户端通过FSDataOutputStream输出流开始写入数据
4、客户端写入数据时,将数据分成一个个数据包(packet 默认64k)。内部组件DataStreamer请求NameNode挑选出合适存储数据副本的一组DataNode地址,默认是3副本存储
DataStreamer将数据包流式传输到pipeline的第一个DataNode,该DataNode存储数据包并将它发送到pipeline的第二个DataNode。同样,第二个DataNode存储数据包并且发送给第三个(也是最后一个)DataNode
5、传输的反方向上,会通过ACK机制校验数据包传输是否成功
6、客户端完成数据写入后,在FSDataOutputStream输出流上调用close()方法关闭
7、DistributedFileSystem联系NameNode告知其文件写入完成,等待NameNode确认

如果管道在2,3之间断掉,会怎样?
因为namenode已经知道文件由哪些块组成(DataStream请求分配数据块),因此仅需等待最小复制快即可成功返回,最小复制参数由dfs.namenode.replication.min指定,默认为1
换句话说,只要一个副本上传成功了就认为是成功了,其他副本可以找其他机器进行复制。如果一个副本都没有成功,那就认为文件上传失败。
在这里插入图片描述

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

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

相关文章

实验三 进程的互斥与同步

文章目录一、 实验目的二、 实验原理三、实验内容四、我的代码内容和现象1、philosopher12、philosopher2这个程序不会发生死锁&#xff0c;因为五、课后习题&#xff1a;1.什么是死锁&#xff1f;产生死锁的原因和必要条件是什么&#xff1f;2.实验中给出的伪代码流程&#xf…

Problem Set 3

1Lagrange Duality Formulate the Lagrange dual problem of the following linear programming prob-lem min cT rs.t.Ax 二b where a ∈R is variable,c ∈ R"&#xff0c;A ∈Rkn, b ∈ Rk. 解&#xff1a;设拉格朗日函数为L(x,λ)cTxλT(Ax−b)\mathcal{L}(x,\lambda)…

第十七章 webpack5项目搭建Vue-Cli(开发模式)

step1–创建项目目录 创建一个目录用来搭建vue-cli的项目 mkdir vue-cli cd vue-clistep2–初始化项目 初始化项目&#xff0c;生成一个package.json文件 npm init -ystep3–编写vue-cli的开发模式配置 新建目录 / |-config | |--webpack.dev.js | |--webpack.prod.js我…

USB TO SPI(上海同旺电子)调试器调试25LC020A

所需设备&#xff1a; 1、USB TO SPI(上海同旺电子)&#xff1b; 2、25LC020A 2Kb 2.5V SPI Serial EEPROM; Microchip 25LC020A 是一款 2 Kb 串行 EEPROM&#xff0c;采用行业标准串行外设接口 (SPI) 兼容串行总线。 该器件被组织为一个 256 x 8 位块&#xff0c;并针对消…

Java安全--CC7

在学CC7的时候我有这么几个疑问 1.为什么要两个LazyMap 2.hashCode那一步怎么计算的 3.为什么要remove yy 4.为什么put两个 我们可以先看一下CC7的链子是怎么走的: 其实分析链子还是从命令执行走到readObject比较好理解&#xff0c;虽然比较麻烦&#xff0c;比较繁琐&#xff0…

机器人机械臂运动学——逆运动学解算

1.情景概述 假设最一般的情况&#xff0c;我们的机械臂有六个自由度&#xff0c;那么从初始状态想要变化到目标的状态&#xff0c;一般情况下我们至少需要进行六次的变换&#xff0c;而这六次变换的矩阵参数隐含在整体的变换矩阵中。 根据之前的知识&#xff0c;左上角的3*3代表…

m基于隐马尔科夫模型(HMM)的手机用户行为预测(MMUB)算法matlab仿真

目录 1.算法描述 2.仿真效果预览 3.MATLAB核心程序 4.完整MATLAB 1.算法描述 隐马尔可夫模型&#xff08;Hidden Markov Model&#xff0c;HMM&#xff09;是一种统计模型&#xff0c;广泛应用在语音识别&#xff0c;词性自动标注&#xff0c;音字转换&#xff0c;概率文法…

R语言中的Nelson-Siegel模型在汇率预测的应用

这篇文章的目的是指导读者逐步使用R编程语言实现Nelson-Siegel模型的步骤。 最近我们被客户要求撰写关于Nelson-Siegel模型的研究报告&#xff0c;包括一些图形和统计输出。 您可能已经知道&#xff0c;估计利率期限结构是任何资产定价的关键&#xff0c;因此对投资者和政策制…

5G无线技术基础自学系列 | 基于Massive MIMO的场景化波束优化

素材来源&#xff1a;《5G无线网络规划与优化》 一边学习一边整理内容&#xff0c;并与大家分享&#xff0c;侵权即删&#xff0c;谢谢支持&#xff01; 附上汇总贴&#xff1a;5G无线技术基础自学系列 | 汇总_COCOgsta的博客-CSDN博客 前面内容提到&#xff0c; 5G中引入了M…

机器人机械臂运动学——运动学正向解算

本博客内容参考台湾大学_林沛群教授_机器人学的课程内容 1.相对运动关系的描述方法 假设有现在这样的一个情景&#xff0c;从左到右有三个转轴&#xff0c;转轴本身可以转动&#xff0c;也可以沿着轴线上下平动&#xff0c;那么我们如何描述其中的运动学关系及其位置关系呢&am…

Linux Red Hat 8.0 cat、cut、sed、tail命令

1.cat&#xff1a; 在终端设备上显示文件内容 常用选项&#xff1a; -n 显示行数&#xff08;空格有编号&#xff09; -b 显示行数&#xff08;空格没有编号&#xff09; 命令格式&#xff1a;cat 选项 文件 特殊用法tac&#xff1a;倒着显示内容 配合重定向使用 查看 test1…

DPDK 多进程

DPDK库里是支持多进程和多线程&#xff0c;本文主要总结多进程的相关的操作。 DPDK多进程使用的关键启动参数&#xff1a; --proc-type&#xff1a;指定一个dpdk进程是主进程还是副进程&#xff08;参数值就用上面的primary或是secondary&#xff0c;或者是auto&#xff09;-…

【Bio】基础生物学 - 五个重要官能团 five important functional group

文章目录1. 羟qiǎng基&#xff08;hydroxyl&#xff09;2. 羧suō基&#xff08;carboxyl&#xff09;3. 氨基&#xff08;amino&#xff09;4. 磷酸盐&#xff08;phosphate&#xff09;5. 巯基&#xff08;sulfhydryl&#xff09;1. 羟qiǎng基&#xff08;hydroxyl&#xf…

最新进展 | Android 自定义机器学习堆栈

作者 / Android 机器学习平台团队相较于服务器端机器学习 (ML)&#xff0c;设备端机器学习有其独特的优势&#xff0c;如支持离线使用、延迟更低、隐私性更高和推理成本更低&#xff0c;因此 Android 中设备端机器学习的使用迅速增长。在构建基于设备端 ML 的功能时&#xff0c…

Android基于perfetto分析native内存泄露

官方文档(可在Chome直接翻译) https://perfetto.dev/docs/data-sources/native-heap-profiler 示例 raw-trace 资源地址 https://download.csdn.net/download/CSqingchen/87321798 本文示例是windows&#xff0c;这里使用了python工具&#xff0c;在Linux和mac同样适用 首先安装…

胡凡 《算法笔记》 上机实战训练指南 3.1 简单模拟

胡凡 《算法笔记》 上机实战训练指南 3.1 持续更新中 , 菜鸡的刷题笔记… 大学到现在了还没咋好好刷过题&#xff0c;该push自己了… 文章目录胡凡 《算法笔记》 上机实战训练指南 3.13.1 简单模拟【PAT B1001】害死人不偿命的&#xff08;3n1&#xff09;猜想【PAT B1032】挖掘…

spring扩展之基于HandlerMapping实现接口灰度发布的demo

背景 面试经常被问到&#xff0c;你了解spring源码吗&#xff1f;有基于spring做过什么扩展吗&#xff1f;除了PropertyPlaceholderConfigurer处理占位符(被说烂了)还有其他的吗&#xff1f; 看了springmvc的源码&#xff0c;有了一个新的案例可讲(吹) 基于HandlerMapping实现…

运营活动没做好,是没有明确目标

有很多运营人在做项目的时候&#xff0c;其实没有一个明确的目标&#xff0c;不清楚自己究竟为什么要做这件事。 我们在做运营方案前&#xff0c;要分析用户的需求有哪些&#xff0c;如何达成目标&#xff0c;制定出一个计划&#xff1a; 1、要做什么——计划 我们需要掌握运…

ES基础入门

ES 一、简介 1、Elastic Stack ES技术栈&#xff1a; ElasticSearch&#xff1a;存数据搜索&#xff1b;QL&#xff1b;Kibana&#xff1a;Web可视化平台&#xff0c;分析。LogStash&#xff1a;日志收集&#xff0c;Log4j:产生日志&#xff1b;log.info(xxx)。。。。 使用…

软件测试面试题和面试流程

自我介绍部分 .... 项目经历 .... 技能部分 性能 使用什么工具&#xff1f;介绍下最近做的性能测试项目&#xff0c;性能测试过程中遇到哪些问题&#xff1f;性能标准谁来定&#xff1f;你们性能测试的流程是什么&#xff1f;什么是分布式&#xff1f;为什么要用分布式&a…