欢迎访问 生活随笔!

生活随笔

当前位置: 首页 > 编程资源 > 编程问答 >内容正文

编程问答

第28课:彻底解密Spark Sort-Based Shuffle排序具体实现内幕和源码详解

发布时间:2024/3/12 编程问答 39 豆豆
生活随笔 收集整理的这篇文章主要介绍了 第28课:彻底解密Spark Sort-Based Shuffle排序具体实现内幕和源码详解 小编觉得挺不错的,现在分享给大家,帮大家做个参考.

第28课:彻底解密Spark Sort-Based Shuffle排序具体实现内幕和源码详解

本文根据家林大神系列课程编写 http://weibo.com/ilovepains

为什么讲解Sorted-Based shuffle?2方面的原因:
一,可能有些朋友看到Sorted-Based Shuffle的时候,会有一个误解,认为Spark基于Sorted-Based Shuffle 它产出的结果是有序的。
二,Sorted-Based Shuffle要排序,涉及到一个排序算法。这部分内容同学们可选学。

 

Sorted-Based Shuffle 的核心是借助于 ExternalSorter 把每个 ShuffleMapTask 的输出,排序到一个文件中 (FileSegmentGroup),为了区分下一个阶段 Reducer Task 不同的内容,它还需要有一个索引文件 (Index) 来告诉下游 Stage 的并行任务,那一部份是属于你的。

 

 



Shuffle Map Task 在ExternalSorter 溢出到磁盘的时候,

总结

以上是生活随笔为你收集整理的第28课:彻底解密Spark Sort-Based Shuffle排序具体实现内幕和源码详解的全部内容,希望文章能够帮你解决所遇到的问题。

如果觉得生活随笔网站内容还不错,欢迎将生活随笔推荐给好友。