《MapReduce 4》--自定义分区、shuffle技术、环形缓冲区(MapOutputBuffer源码解析)、Maptask源码解析

如何自定义分区:     原理：int getPartition(LongWritable key, Text value, int numPartitions)                此方法的返回值为分区的索引(分区就是由索引做为惟一标识符)，                该方法肯定当前key/value属于哪一个索引对应的分区。                因为 if (parti

>>阅读原文<<