public class HashPartitioner extends Partitioner
Partitioner
that implements hash-based partitioning using
Java's Object.hashCode
.
Java arrays have hashCodes that are based on the arrays' identities rather than their contents, so attempting to partition an RDD[Array[_} or RDD[(Array[_], _)] using a HashPartitioner will produce an unexpected or incorrect result.
Constructor and Description |
---|
HashPartitioner(int partitions) |
Modifier and Type | Method and Description |
---|---|
boolean |
equals(Object other) |
int |
getPartition(Object key) |
int |
hashCode() |
int |
numPartitions() |
defaultPartitioner
public boolean equals(Object other)
equals
in class Object
public int getPartition(Object key)
getPartition
in class Partitioner
public int hashCode()
hashCode
in class Object
public int numPartitions()
numPartitions
in class Partitioner