public class IndexUpdatePartitioner extends Object implements Partitioner<Shard,IntermediateForm>
Constructor and Description |
---|
IndexUpdatePartitioner() |
Modifier and Type | Method and Description |
---|---|
void |
configure(JobConf job)
Initializes a new instance from a
JobConf . |
int |
getPartition(Shard key,
IntermediateForm value,
int numPartitions)
Get the paritition number for a given key (hence record) given the total
number of partitions i.e.
|
public int getPartition(Shard key, IntermediateForm value, int numPartitions)
Partitioner
Typically a hash function on a all or a subset of the key.
getPartition
in interface Partitioner<Shard,IntermediateForm>
key
- the key to be paritioned.value
- the entry value.numPartitions
- the total number of partitions.key
.public void configure(JobConf job)
JobConfigurable
JobConf
.configure
in interface JobConfigurable
job
- the configurationCopyright © 2010 The Apache Software Foundation