org.terrier.structures.indexing.singlepass.hadoop

Class HadoopRunIteratorFactory

java.lang.Object

org.terrier.structures.indexing.singlepass.RunIteratorFactory

org.terrier.structures.indexing.singlepass.hadoop.HadoopRunIteratorFactory

public class HadoopRunIteratorFactory
extends RunIteratorFactory

Creates a new Iterator over runs which can be used within the Hadoop framework.

Since:

2.2

Author:

Craig Macdonald

Field Summary

Fields inherited from class org.terrier.structures.indexing.singlepass.RunIteratorFactory

numberOfFields

Constructor Summary

Constructors

Constructor and Description
HadoopRunIteratorFactory(Iterator<MapEmittedPostingList> _postingIterator, Class<? extends PostingInRun> _postingClass, int numberOfFields) constructor

Method Summary

Methods

Modifier and Type	Method and Description
RunIterator	createRunIterator(int runNumber) Open the RunIterator for the specified run number
void	setRunPostingIterator(Iterator<MapEmittedPostingList> _postingIterator) Update the posting iterator currently being used
void	setTerm(String _term) Update the term which is currently being processed

Methods inherited from class java.lang.Object

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

Constructor Detail

HadoopRunIteratorFactory

public HadoopRunIteratorFactory(Iterator<MapEmittedPostingList> _postingIterator,
                        Class<? extends PostingInRun> _postingClass,
                        int numberOfFields)

constructor

Parameters:

_postingIterator -

_postingClass -

numberOfFields -

Method Detail

createRunIterator

public RunIterator createRunIterator(int runNumber)
                              throws Exception

Description copied from class: RunIteratorFactory

Open the RunIterator for the specified run number

Specified by:

createRunIterator in class RunIteratorFactory

Throws:

Exception

setRunPostingIterator

public void setRunPostingIterator(Iterator<MapEmittedPostingList> _postingIterator)

Update the posting iterator currently being used

setTerm

public void setTerm(String _term)

Update the term which is currently being processed