Partition和ReduceTask的关系

先看源码： numPartitions = conf.getNumReduceTasks(); if (numPartitions > 1) { //设置了ReduceTask个数后（大于1），默认通过下面的getPartition()对数据进行分区 partitioner = (Partition
posted @ 2022-06-02 15:52  Ji_Lei  阅读(99)  评论(0)  编辑  收藏  举报