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

java.lang.Object
  extended by org.terrier.structures.indexing.singlepass.RunIteratorFactory
      extended by 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
HadoopRunIteratorFactory(Iterator<MapEmittedPostingList> _postingIterator, Class<? extends PostingInRun> _postingClass, int numberOfFields)
          constructor
 
Method Summary
 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



Terrier 3.6. Copyright © 2004-2011 University of Glasgow