org.terrier.structures.indexing.singlepass.hadoop

Class Inv2DirectMultiReduce.ByDocidPartitioner<K>

java.lang.Object

org.terrier.structures.indexing.singlepass.hadoop.Inv2DirectMultiReduce.ByDocidPartitioner<K>

All Implemented Interfaces:

org.apache.hadoop.mapred.JobConfigurable, org.apache.hadoop.mapred.Partitioner<org.apache.hadoop.io.VIntWritable,K>

Direct Known Subclasses:

Inv2DirectMultiReduce.ByDocidPartitionerPosting

Enclosing class:

Inv2DirectMultiReduce

public static class Inv2DirectMultiReduce.ByDocidPartitioner<K>
extends Object
implements org.apache.hadoop.mapred.Partitioner<org.apache.hadoop.io.VIntWritable,K>

Partitioner partitioning by docid

Constructor Summary

Constructors

Constructor and Description
Inv2DirectMultiReduce.ByDocidPartitioner()

Method Summary

Methods

Modifier and Type	Method and Description
void	configure(org.apache.hadoop.mapred.JobConf job)
int	getPartition(org.apache.hadoop.io.VIntWritable docid, K posting, int numberOfReducers)
static void	setNumberOfDocments(org.apache.hadoop.mapred.JobConf job, int numDocs) set number of documents

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

Inv2DirectMultiReduce.ByDocidPartitioner

public Inv2DirectMultiReduce.ByDocidPartitioner()

Method Detail

getPartition

public int getPartition(org.apache.hadoop.io.VIntWritable docid,
               K posting,
               int numberOfReducers)

Specified by:

getPartition in interface org.apache.hadoop.mapred.Partitioner<org.apache.hadoop.io.VIntWritable,K>

configure

public void configure(org.apache.hadoop.mapred.JobConf job)

Specified by:

configure in interface org.apache.hadoop.mapred.JobConfigurable

setNumberOfDocments

public static void setNumberOfDocments(org.apache.hadoop.mapred.JobConf job,
                       int numDocs)

set number of documents

Parameters:

job -

numDocs -