你可以在这里看到实现:https://github.com/apache/spark/blob/ffa05c84fe75663fc33f3d954d1cb1e084ab3280/python/pyspark/rdd.py#L804它与“普通”reduce函数有何不同？depth=2是什么意思？我不希望reducer函数在分区上线性传递，但是首先减少每个可用的对，然后像这样迭代直到我只有一对并将其减少到1，如图所示:treeReduce实现了吗？ 最佳答案 标准reduce正在采用函数的包装版本并将其用于mapPartitions.之