MapReduce 排序和洗牌如何工作？

我正在使用 yelps MRJob 库来实现映射缩减功能。我知道 MapReduce 有一个内部排序和洗牌算法，它根据键对值进行排序。所以如果我在地图阶段后得到以下结果

(1, 24) (4, 25) (3, 26)

我知道排序和洗牌阶段将产生以下输出

(1, 24) (3, 26) (4, 25)

正如预期的那样

但是，如果我有两个相似的键和不同的值，为什么排序和洗牌阶段会根据出现的第一个值对数据进行排序？

例如 如果我有来自映射器的以下值列表

(2, <25, 26>) (1, <24, 23>) (1, <23, 24>) 

预期输出是

(1, <24, 23>) (1, <23, 24>) (2, <25, 26>)

但我得到的输出是

(1, <23, 24>) (1, <24, 23>) (2, <25, 26>)

这个 MRjob 库具体吗？无论如何，有没有办法停止这种基于值的排序？

CODE

from mrjob.job import MRJob
import math

class SortMR(MRJob):



def steps(self):
    return [
        self.mr(mapper=self.rangemr,
                reducer=self.rangesort)]


def rangemr(self, key, line):
    for a in line.split():
        yield 1,a


def rangesort(self,numid,line):
    for a in line:
        yield(1, a)


if __name__ == '__main__':
    SortMR.run()

对值进行“排序”的唯一方法是使用包含值本身的一些信息的复合键。然后，您的键的compareTo 方法可以确保键首先按实际键组件排序，然后按值组件排序。最后，您需要一个组分区器来确保在缩减程序中具有相同“键”组件（实际键）的所有键都被认为是相等的，并且在对reduce方法的一次调用中迭代关联的值。

这被称为“二次排序”，类似的问题 https://stackoverflow.com/questions/14320313/mapreduce-sort-values对此提供了一些示例链接。