對於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