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 |
numPartitions() |
defaultPartitioner
public int numPartitions()
numPartitions
in class Partitioner
public int getPartition(Object key)
getPartition
in class Partitioner
public boolean equals(Object other)
equals
in class Object