本文介绍了如何使用上JavaPairRDD最大方法的处理方法，对大家解决问题具有一定的参考价值，需要的朋友们下面随着小编来一起学习吧！
问题描述
我想在 JavaPairRDD 使用max但不能使它工作。
I want to use max in JavaPairRDD but couldn't make it work.
JavaPairRDD<Integer, String> someRdd = (initialisation)
String maxValue = someRdd.max() //not working
我的code：
推荐答案
实施其描述所需的排序比较：
Implement comparator which describes desired ordering:
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;
}
}
将它传递给最大方法：
someRdd.max(new DummyComparator());
这篇关于如何使用上JavaPairRDD最大方法的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持！