对于mapreduce倒序只须要创建一个类,而后继承WritableComparator 在重写 Compare函数最后在main里调用一下,就能够实现倒序排序:ide
代码:函数
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里插入:spa
job.setSortComparatorClass(Sort.class); code