Hadoop框架之MapReduce框架原理（二）

点击蓝色字免费订阅，每天收到这样的好信息

context.write(k, NullWritable.get());


output.write(key, value);


collector.collect(key,value,partitioner.getPartition(key, value, partitions));


        HashPartitioner();


collect()


        close()


        collect.flush()


sortAndSpill()


    sort()   QuickSort


mergeParts();


   


collector.close();