如何在Java中使用repartitionAndSortWithinPartitions

Question

任何人都可以提供一個關於如何在Java中使用repartitionAndSortWithinPartitions而不是scala的清晰示例。

在此先感謝！ 阿尼

Answer 1

採取JavaPairRDD<K, V>：

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

定義分區：

Partitioner partitioner = ...; 

如果需要的話可以選擇定義Comparator<K>。

Comparator<K> comparator = ...; 

Apply方法：

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

或

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