Class HashPartitioner<K,V>

java.lang.Object
org.apache.hadoop.mapreduce.Partitioner<K,V>
org.apache.hadoop.mapreduce.lib.partition.HashPartitioner<K,V>

@Public @Stable public class HashPartitioner<K,V> extends Partitioner<K,V>
Partition keys by their Object.hashCode().
  • Constructor Details

    • HashPartitioner

      public HashPartitioner()
  • Method Details

    • getPartition

      public int getPartition(K key, V value, int numReduceTasks)
      Use Object.hashCode() to partition.
      Specified by:
      getPartition in class Partitioner<K,V>
      Parameters:
      key - the key to be partioned.
      value - the entry value.
      numReduceTasks - the total number of partitions.
      Returns:
      the partition number for the key.