@InterfaceAudience.Public @InterfaceStability.Stable public class RehashPartitioner<K,V> extends Partitioner<K,V>
Object.hashCode()to get smoother distribution between partitions which may improve reduce reduce time in some cases and should harm things in no cases. This partitioner is suggested with Integer and Long keys with simple patterns in their distributions.
|Constructor and Description|
|Modifier and Type||Method and Description|
public int getPartition(K key, V value, int numReduceTasks)
key- the key to be partioned.
value- the entry value.
numReduceTasks- the total number of partitions.
Copyright © 2018 Apache Software Foundation. All rights reserved.