java - 如何在Spark Java中根据列表值对列表进行排序？

我想按此价格升序对房屋分类。

public class Home implements Serializable{

        private double price = Math.Random() * 1000;

    }

这就是我按顺序进行的方式。

ArrayList<Home> city; // Assume it is initallized with some values
Arrays.sort(this.city,new Comparator<House>(){
                public int compare (House o1, House o2){
                if (o1.getPrice() > o2.getPrice()) {
                    return -1;
                } else if (o1.getPrice() < o2.getPrice()) {
                    return 1;
                }
                return 0;
            }
            });

现在，我想使用Apache Spark Java对其进行排序。


  方法一

  JavaRDD<House> r2 = houseRDD.sortBy(  i -> {return i.getPrice(); }, true, 1 );

  方法二：

JavaRDD<House> r = populationRDD.sortBy( new Function<House, Double>() {
                private static final long serialVersionUID = 1L;

                @Override
                public Double call(Individual value ) throws Exception {
                    return  value.getPrice();
                }

            }, true, 1 );

上面的方法有什么问题，我没有得到下面的例外-

java.lang.ClassCastException：无法将房屋强制转换为java.lang.Comparable

java.lang.ClassCastException: House cannot be cast to java.lang.Comparable
    at org.spark_project.guava.collect.NaturalOrdering.compare(NaturalOrdering.java:28)
    at scala.math.LowPriorityOrderingImplicits$$anon$7.compare(Ordering.scala:153)
    at scala.math.Ordering$$anon$4.compare(Ordering.scala:111)
    at org.apache.spark.util.collection.Utils$$anon$1.compare(Utils.scala:35)
    at org.spark_project.guava.collect.Ordering.max(Ordering.java:551)
    at org.spark_project.guava.collect.Ordering.leastOf(Ordering.java:667)
    at org.apache.spark.util.collection.Utils$.takeOrdered(Utils.scala:37)
    at org.apache.spark.rdd.RDD$$anonfun$takeOrdered$1$$anonfun$30.apply(RDD.scala:1393)
    at org.apache.spark.rdd.RDD$$anonfun$takeOrdered$1$$anonfun$30.apply(RDD.scala:1390)
    at org.apache.spark.rdd.RDD$$anonfun$mapPartitions$1$$anonfun$apply$23.apply(RDD.scala:785)
    at org.apache.spark.rdd.RDD$$anonfun$mapPartitions$1$$anonfun$apply$23.apply(RDD.scala:785)
    at org.apache.spark.rdd.MapPartitionsRDD.compute(MapPartitionsRDD.scala:38)
    at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:319)
    at org.apache.spark.rdd.RDD.iterator(RDD.scala:283)
    at org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:70)
    at org.apache.spark.scheduler.Task.run(Task.scala:86)
    at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:274)
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
    at java.lang.Thread.run(Thread.java:745)

  根据评论新的家庭课

public class Home implements Serializable,Comparable<Home>{

        private double price = Math.Random() * 1000;

@Override
    public int compareTo(House o) {
        return Double.compare(this.getPrice(),o.getPrice());
    }
    }

最佳答案

豪斯似乎没有实现类似的接口。

How to implement the Java comparable interface?

关于java - 如何在Spark Java中根据列表值对列表进行排序？，我们在Stack Overflow上找到一个类似的问题：https://stackoverflow.com/questions/40900570/