如何使用上JavaPairRDD最大方法 [英] How to use max method on 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： http://ideone.com/0YXCJw

推荐答案

实施其描述所需的排序比较：

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最大方法的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！