对于mapreduce倒序只需要建立一个类,然后继承WritableComparator 在重写 Compare函数最后在main里调用一下,就可以实现倒序排序:
代码:
1 public static class Sort extends WritableComparator { 2 public Sort(){ 3 //这里就是看你map中填的输出key是什么数据类型,就给什么类型 4 super(DoubleWritable.class,true); 5 } 6 @Override 7 public int compare(WritableComparable a, WritableComparable b) { 8 return -a.compareTo(b);//加个负号就是倒序,把负号去掉就是正序。 9 } 10 }
在main里插入:
job.setSortComparatorClass(Sort.class);