Как использовать repartitionAndSortWithinPartitions в Java

Question

Может ли кто-нибудь дать ясный пример того, как использовать repartitionAndSortWithinPartitions в Java, а не scala.

Спасибо заранее! Ани

Answer 1

Возьмите JavaPairRDD<K, V>:

JavaPairRDD<K, V> rdd = ...; 

Определение разметки:

Partitioner partitioner = ...; 

при необходимости желании определить Comparator<K>.

Comparator<K> comparator = ...; 

Применить метод:

JavaPairRDD<K, V> repartitioned = 
    rdd.repartitionAndSortWithinPartitions(partitioner); 

или

JavaPairRDD<K, V> repartitioned = 
    rdd.repartitionAndSortWithinPartitions(partitioner, comparator);