hadoop Partitioner 分区
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 import org.apache.hadoop.io.Text; import org.apache.hadoop.mapreduce.Partitioner; /* 测试 Partitioner 分区 */ public class TestPartitioner extends Partitioner<Text, Text>{ /* * 接受的两个是应该是输入的<key value> 的数据类型 然后根据传进来的 的key 应该有三种结果long right short 然后进行区分输出文件 */ @Override public int getPartition(Text key, Text value, int numPartition) { /* * numPartition = job.setNumReduceTasks(3); 在运行类设置 * numPartiti...
