Uses of Class
org.terrier.structures.indexing.singlepass.hadoop.SplitEmittedTerm

Packages that use SplitEmittedTerm

org.terrier.indexing.hadoop	Provides classes for Terrier's MapReduce indexer.
org.terrier.structures.indexing.singlepass.hadoop	Provides classes implemeting the Hadoop MapReduce indexing in Terrier.

Uses of SplitEmittedTerm in org.terrier.indexing.hadoop

Fields in org.terrier.indexing.hadoop with type parameters of type SplitEmittedTerm

protected org.apache.hadoop.mapred.OutputCollector<SplitEmittedTerm,MapEmittedPostingList>

Hadoop_BasicSinglePassIndexer.outputPostingListCollector output collector for the current map indexing process

Methods in org.terrier.indexing.hadoop with parameters of type SplitEmittedTerm

void	Hadoop_BasicSinglePassIndexer.reduce(SplitEmittedTerm Term, java.util.Iterator<MapEmittedPostingList> postingIterator, org.apache.hadoop.mapred.OutputCollector<java.lang.Object,java.lang.Object> output, org.apache.hadoop.mapred.Reporter reporter) Main reduce algorithm step.

Method parameters in org.terrier.indexing.hadoop with type arguments of type SplitEmittedTerm

void	Hadoop_BasicSinglePassIndexer.map(org.apache.hadoop.io.Text key, SplitAwareWrapper<Document> value, org.apache.hadoop.mapred.OutputCollector<SplitEmittedTerm,MapEmittedPostingList> _outputPostingListCollector, org.apache.hadoop.mapred.Reporter reporter) Map processes a single document.

Uses of SplitEmittedTerm in org.terrier.structures.indexing.singlepass.hadoop

Fields in org.terrier.structures.indexing.singlepass.hadoop with type parameters of type SplitEmittedTerm

protected org.apache.hadoop.mapred.OutputCollector<SplitEmittedTerm,MapEmittedPostingList>

HadoopRunWriter.outputCollector output collector of Map task

Methods in org.terrier.structures.indexing.singlepass.hadoop that return SplitEmittedTerm

static SplitEmittedTerm

SplitEmittedTerm.createNewTerm(java.lang.String term, int splitno, int flushno) Factory method for creating a new Term key object

Methods in org.terrier.structures.indexing.singlepass.hadoop with parameters of type SplitEmittedTerm

int	SplitEmittedTerm.SETRawComparatorTerm.compare(SplitEmittedTerm o1, SplitEmittedTerm o2)
int	SplitEmittedTerm.SETRawComparatorTermSplitFlush.compare(SplitEmittedTerm term1, SplitEmittedTerm term2) Compares Term key 1 to Term key 2.
int	SplitEmittedTerm.compareTo(SplitEmittedTerm term2) Compares this Term key to another term key.
int	SplitEmittedTerm.SETPartitioner.getPartition(SplitEmittedTerm term, MapEmittedPostingList posting, int numPartitions) Retuns the partition for the specified term and posting list, given the specified number of partitions.
int	SplitEmittedTerm.SETPartitionerLowercaseAlphaTerm.getPartition(SplitEmittedTerm term, MapEmittedPostingList posting, int numPartitions) Retuns the partition for the specified term and posting list, given the specified number of partitions.

Constructor parameters in org.terrier.structures.indexing.singlepass.hadoop with type arguments of type SplitEmittedTerm

HadoopRunWriter(org.apache.hadoop.mapred.OutputCollector<SplitEmittedTerm,MapEmittedPostingList> _outputCollector, java.lang.String _mapId, int _splitId, int _flushNo)
Create a new HadoopRunWriter, specifying the output collector of the map task the run number and the flush number.