Spark-shuffle源码细读一:ShuffleManager_sparksql shuffledrowrdd-程序员宅基地

技术标签: spark  big data  大数据  

@Author Jeffrey.miao
转载请标明出处: Spark-shuffle源码细读一:ShuffleManager_The_Inertia的博客-程序员宅基地

欢迎关注个人知乎专栏:Spark源码学习成长 - 知乎

version:spark 3.0.1

ShuffleManager目前只有一个实现SortShuffleManager。分析其源码:

一.成员变量

1.taskIdMapsForShuffle

  /**
   * A mapping from shuffle ids to the task ids of mappers producing output for those shuffles.
   */
  private[this] val taskIdMapsForShuffle = new ConcurrentHashMap[Int, OpenHashSet[Long]]()

taskIdMapsForShuffle,记录了ShuffleId和其对应的taskIds的映射关系。

一个ShuffleDependency对应一个shuffleId(从0开始累加)

<
版权声明:本文为博主原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。
本文链接:https://blog.csdn.net/the_inertia/article/details/122753341

智能推荐

Java Selenium Actions模拟鼠标拖动dragAndDrop总结_selenium actions.draganddropby-程序员宅基地

文章浏览阅读1.2w次。鼠标拖动APIActions action = new Actions(webdriver);##source-要拖动的元素A,target-拖动元素A到达的目标元素action.dragAndDrop(source, target);##source-要拖动的元素A,拖动元素移动多少,标准以元素A左上角为准,拖动元素相对元素A移到右边是x是正值,左边是负值,拖动元素相对元素A移到上_selenium actions.draganddropby

amd显卡RX560控制功耗问题_a卡560功耗-程序员宅基地

文章浏览阅读4.2w次。前言现在显卡市场可以说就是 amd 和 英伟达 的双雄会。经过漫长的发展,英伟达显然技高一筹,在核心技术上牢牢压了AMD一头。价格就是最有力的证明。比如说今天我要说的RX560D。都说rx560可以媲美1050ti,但是却比1050ti便宜了一半,为什么?是amd为了消费者,所以他们有商业道德,不屑于赚取多余的金钱?我想应该不会有这样的商家存在吧。遗憾的是rx560只要不是xt,或..._a卡560功耗

springboot停车场车辆定位管理可视化分析系统的设计与实现 毕业设计-附源码101702-程序员宅基地

文章浏览阅读111次。该系统采用Springboot框架、JSP技术、Ajax技术进行业务系统的编码及其开发,实现了本系统的全部功能。本系统采取组件化的方式对系统进行拆分,并对数据库中各个表的增删查改、表与表之间的约束关系进行分析与设计,最终实现符合用户需求功能的商业级应用。

vue页面报错,TypeError: Cannot read property ‘_wrapper‘ of undefined_页面报错vue.min.js:6-程序员宅基地

文章浏览阅读2.9k次。vue页面报错崩溃卡死,报了这个错TypeError: Cannot read property '_wrapper' of undefined at Qr (vue.min.js:6) at rt (vue.min.js:6) at Array.ei (vue.min.js:6) at x (vue.min.js:6) at vue.min.js:6 at x (vue.min.js:6) at vue.min.js:6 at x (vue_页面报错vue.min.js:6

选择排序算法-程序员宅基地

文章浏览阅读153次。大家好,我是Yang。欢迎大家来到我的博客,希望能和大家多多交流。地址:https://blog.csdn.net/Ziyang1060。如果大家觉得看完之后能有点收获,不妨点个赞来庆祝庆祝~选择排序算法算法复杂度:O(n2n^2n2)void selection_sort(int arr[], int size){ int min_index;//最小值的索引 int i, j;...

启用Django服务时报错:django.core.exceptions.ImproperlyConfigured: The INSTALLED_APPS setting must be a list...-程序员宅基地

文章浏览阅读844次。启用Django服务时(Python manage.py runserver),报错:django.core.exceptions.ImproperlyConfigured: The INSTALLED_APPS setting must be a list or a tuple.原因:Django项目XXX目录下setting.py文件中INSTALLED_APPS ..._django.core.exceptions.improperlyconfigured: the installed_apps setting must

随便推点

Python小白逆袭大神七日打卡营飞桨paddlepaddle_path = 'work/' 'pics/' name '/-程序员宅基地

文章浏览阅读782次。这里写自定义目录标题Python小白逆袭大神七日打卡营全纪录新的改变功能快捷键合理的创建标题,有助于目录的生成如何改变文本的样式插入链接与图片如何插入一段漂亮的代码片生成一个适合你的列表创建一个表格设定内容居中、居左、居右SmartyPants创建一个自定义列表如何创建一个注脚注释也是必不可少的KaTeX数学公式新的甘特图功能,丰富你的文章UML 图表FLowchart流程图导出与导入导出导入P..._path = 'work/' 'pics/' name '/

px4飞控和qgc通信机制整理_airsim和qground交互-程序员宅基地

文章浏览阅读2k次,点赞6次,收藏31次。连接多架飞机时老是不反应,整理一下飞控和qgc的通信机制吧全部消息整理出来太庞大了,以心跳包做个示例,打字太累,直接贴图,qgc的后面再补上_airsim和qground交互

使用MQTT客户端连接阿里云MQTT服务器_mqtt 客户端发数据 服务器需要开端口吗-程序员宅基地

文章浏览阅读1.2w次,点赞2次,收藏49次。本文是转载的,原文请戳这里查看!~摘要: 物联网全栈教程-从云端到设备(八) 一 这一篇文章零妖老哥将给你展示两个电脑软件的使用方法,将极大地方便你调试与MQTT有关的物联网项目。一个叫MQTT客户端用来模拟设备向云端发送数据和接收云端的数据;另一个叫作MQTT单片机编程小工具,是技小新针对阿里云MQTT服务器连接过程中的痛点,自己编写的一个电脑程序,用来生成连接阿里云MQTT服务器时的账号密码..._mqtt 客户端发数据 服务器需要开端口吗

drivers\base\sys.c_devices_subsys在哪里定义的-程序员宅基地

文章浏览阅读1.9k次。小结: 从sysdev_shutdown函数的实现,我们可以大概的分析一下驱动的层次模式如下:1、最顶层的是system_subsys,所有的cls都挂载在他的链表中2、每一个cls有一个驱动链表,这个驱动链表又可以按sysdev进行一个分组,但是分组只是为了管理方便,驱动还是挂载在cls下的。3、分组虽然只是管理,但是驱动的一些函数执行,比如shutdown,resume等,_devices_subsys在哪里定义的

计算机组装过程中需要注意什么,PCB组装过程中需要注意哪些问题-程序员宅基地

文章浏览阅读137次。PCB是小型玩具或复杂计算机的任何电子设备的组成部分。其复杂的互连组件包括电阻器,二极管,电容器等,使器件能够串联工作。从某种意义上说,它就像是系统的“大脑”。在高可靠性系统中 - 尤其是石油钻井,太空卫星和其他故障可能会产生破坏性后果。这是至关重要的,因此PCB组装过程是完美无缺的,并且组装中常见的错误被注意到。以下是需要注意的一些因素:供应链管理 -为了能够创建高质量的PCB,需要整理的一件事..._组装耳机pcb问题注意事项

retrofit2.adapter.rxjava.HttpException: HTTP 504 Unsatisfiable Request (only-if-cached)_retrofit2.adapter.rxjava2.httpexception: http 504 -程序员宅基地

文章浏览阅读3.9k次。retrofit2.adapter.rxjava.HttpException: HTTP 504 Unsatisfiable Request (only-if-cached)03-31 10:57:21.473 5267-5267/com.moreunion.zhenghao W/System.err: at retrofit2.adapter.rxjava.OperatorMapResp..._retrofit2.adapter.rxjava2.httpexception: http 504 unsatisfiable request (onl

推荐文章

热门文章

相关标签