如何使用最多的方法上JavaPairRDD

Question

我想在JavaPairRDD使用max但不能使它工作。

JavaPairRDD<Integer, String> someRdd = (initialisation) 

String maxValue = someRdd.max() //not working 

我的代碼：http://ideone.com/0YXCJw

Answer 1

實施該專利描述了所需的排序比較：

import scala.Tuple2; 
import java.io.Serializable; 

class DummyComparator implements 
     Comparator<Tuple2<Integer, String>>, Serializable { 
    public int compare(Tuple2<Integer, String> x, Tuple2<Integer, String> y) { 
     return -1; 
    } 
} 

它傳遞到max方法：

someRdd.max(new DummyComparator()); 

Answer 2

這是我用過的東西。

class DummyComparator implements Serializable, 
    Comparator<Tuple2<Integer, String>> { 
    @Override 
    public int compare(Tuple2<Integer, String> o1, Tuple2<Integer, String> o2) { 
     return Integer.compare(o1._1(), o2._1()); 
    } 
}