Как отсортировать список по его значению в искровом java?

Question

Я хочу сортировать дома по этой цене в порядке возрастания.

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()); 
    } 
    } 

Answer 1

List<Home> homes; // initialize it with some data 
JavaRDD<Individual> homeRDD = SparkUtil.getSparkContext().parallelize(homes); 
    public class Home implements Serializable,Comparable<Home>{ 

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

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

Попробовать же код

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

houseRDD.top(4); // this will output top 4 houses 

Answer 2

кажется Дом не реализует сопоставимый интерфейс.

How to implement the Java comparable interface?