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

HadoopRunIteratorFactory(java.util.Iterator<MapEmittedPostingList> _postingIterator, java.lang.Class<? extends PostingInRun> _postingClass, int numberOfFields)
constructor

Method Summary

RunIterator	createRunIterator(int runNumber) Open the RunIterator for the specified run number
void	setRunPostingIterator(java.util.Iterator<MapEmittedPostingList> _postingIterator) Update the posting iterator currently being used
void	setTerm(java.lang.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(java.util.Iterator<MapEmittedPostingList> _postingIterator,
                                java.lang.Class<? extends PostingInRun> _postingClass,
                                int numberOfFields)

constructor

Parameters:

_postingIterator -

_postingClass -

numberOfFields -

Method Detail

createRunIterator

public RunIterator createRunIterator(int runNumber)
                              throws java.lang.Exception

Description copied from class: RunIteratorFactory

Open the RunIterator for the specified run number

Specified by:

createRunIterator in class RunIteratorFactory

Throws:

java.lang.Exception

setRunPostingIterator

public void setRunPostingIterator(java.util.Iterator<MapEmittedPostingList> _postingIterator)

Update the posting iterator currently being used

setTerm

public void setTerm(java.lang.String _term)

Update the term which is currently being processed