public static class SplitEmittedTerm.SETPartitioner extends Object implements org.apache.hadoop.mapred.Partitioner<SplitEmittedTerm,MapEmittedPostingList>, org.apache.hadoop.mapred.JobConfigurable
Constructor and Description |
---|
SplitEmittedTerm.SETPartitioner() |
Modifier and Type | Method and Description |
---|---|
int |
calculatePartition(int splitno,
int numPartitions)
Calculates the partitions for a given split number.
|
void |
configure(org.apache.hadoop.mapred.JobConf conf)
Configure the partitioner functionality, i.e.
|
int |
getPartition(SplitEmittedTerm term,
MapEmittedPostingList posting,
int numPartitions)
Retuns the partition for the specified term and posting list, given the specified
number of partitions.
|
public void configure(org.apache.hadoop.mapred.JobConf conf)
configure
in interface org.apache.hadoop.mapred.JobConfigurable
public int getPartition(SplitEmittedTerm term, MapEmittedPostingList posting, int numPartitions)
getPartition
in interface org.apache.hadoop.mapred.Partitioner<SplitEmittedTerm,MapEmittedPostingList>
public int calculatePartition(int splitno, int numPartitions)
splitno
- - which split index, starting at 0numPartitions
- - number of partitions (reducers) configuredTerrier 4.0. Copyright © 2004-2014 University of Glasgow