码农知识堂 - 1000bd
  •   Python
  •   PHP
  •   JS/TS
  •   JAVA
  •   C/C++
  •   C#
  •   GO
  •   Kotlin
  •   Swift
  • Hadoop3:MapReduce源码解读之Map阶段的FileInputFormat的切片原理(2)


    Job那块的断点代码截图省略,直接进入切片逻辑
    参考:Hadoop3:MapReduce源码解读之Map阶段的Job任务提交流程(1)

    4、FileInputFormat切片源码解析

    切片入口
    在这里插入图片描述
    获取切片
    在这里插入图片描述
    获取切片最大的Size和切片最小的Size
    在这里插入图片描述
    判断文件是否可以切片,如果文件不支持切片,则整体处理
    这里只考虑支持切片的代码逻辑
    在这里插入图片描述
    根据切片大小配置,及块大小配置,计算出切片最终取值
    在这里插入图片描述
    此处可以看出,如果块大小配置在切片大小之间的值,则切片大小取块大小。
    在这里插入图片描述
    这里可以看出,切片是对每一个文件单独计算的,不是把所有文件累加到一起的大小进行计算切片数量。
    在这里插入图片描述

    切片的一个代码层面的处理逻辑。
    如果,文件大小小于切片大小的1.1倍,则不增加切片。
    然后根据splitSize值去划分数据块
    在这里插入图片描述
    生成临时切片文件
    在这里插入图片描述
    创建配置信息文件到临时文件夹中
    在这里插入图片描述

    总结

    FileInputFormat类的继承关系
    在这里插入图片描述
    主要关注该类里面的getSplits方法
    在这里插入图片描述
    整体流程梳理
    在这里插入图片描述在这里插入图片描述
    常用API
    在这里插入图片描述

  • 相关阅读:
    jupyter notebook插件安装及插件推荐
    【开源】新生报到网站 JAVA+Vue.js+SpringBoot+MySQL
    【Greenhills】MULTIIDE集成第三方的编辑器进行源文件编辑工作
    腾讯云16核服务器配置大全_16核CPU型号性能测评
    QT中如何对引入的第三方库进行翻译
    机器学习之自训练&协同训练
    【Node.js】01 —— fs模块全解析
    pycharm复习
    ISIS—ISIS邻居建立&影响ISIS邻居建立的因素有哪些—03
    【fairseq】RuntimeError: Unrecognized tensor type ID: AutogradCUDA
  • 原文地址:https://blog.csdn.net/Brave_heart4pzj/article/details/139474193
  • 最新文章
  • 沪漂五周年了:我越来越迷茫了
    Agentic Skill Routing 实战:别再把所有 Skill 塞进 AI Agent 上下文
    MySQL-Seconds_behind_master的精度误差
    [MAF预定义ChatClient中间件-03]CachingChatClient——利用缓存省钱省时间
    AI的至暗历史:从万众期待到被政府撤资,AI的两次死亡徘徊
    Agent OS :五种驯服不确定性的范式
    PortSwigger SQL注入LAB11
    数据库即时编译JIT
    [Begin]AI Learn Data Day 0
    深度学习进阶(二十七)现代 LLM 的核心架构设计其二:SwiGLU
  • 热门文章
  • 十款代码表白小特效 一个比一个浪漫 赶紧收藏起来吧!!!
    奉劝各位学弟学妹们,该打造你的技术影响力了!
    五年了,我在 CSDN 的两个一百万。
    Java俄罗斯方块,老程序员花了一个周末,连接中学年代!
    面试官都震惊,你这网络基础可以啊!
    你真的会用百度吗?我不信 — 那些不为人知的搜索引擎语法
    心情不好的时候,用 Python 画棵樱花树送给自己吧
    通宵一晚做出来的一款类似CS的第一人称射击游戏Demo!原来做游戏也不是很难,连憨憨学妹都学会了!
    13 万字 C 语言从入门到精通保姆级教程2021 年版
    10行代码集2000张美女图,Python爬虫120例,再上征途
小工具 小游戏
Copyright © 2022 侵权请联系2656653265@qq.com    京ICP备2022015340号-1

京公网安备 11010502049817号