public class HadoopRunPostingIterator extends RunIterator
Modifier and Type | Field and Description |
---|---|
protected String |
mapNo
Map number
|
protected Iterator<MapEmittedPostingList> |
postingIterator
Runs To Be Merged
|
protected int |
splitNo
The Split that the current posting comes from
|
protected String |
term
Term that we're processing
|
flushNo, numberOfFields, posting, postingClass
Constructor and Description |
---|
HadoopRunPostingIterator(Class<? extends PostingInRun> postingClass,
int runNo,
Iterator<MapEmittedPostingList> _postingiterator,
String _term,
int numFields)
Constructs a new RunPostingIterator.
|
Modifier and Type | Method and Description |
---|---|
String |
getMapNo()
Returns the map that the current posting came from
|
int |
getSplitNo() |
boolean |
hasNext()
Move to the next posting
|
PostingInRun |
next()
Return the next PostingInRun
|
close, createPosting, current, getRunNo, remove
protected Iterator<MapEmittedPostingList> postingIterator
protected String mapNo
protected String term
protected int splitNo
public HadoopRunPostingIterator(Class<? extends PostingInRun> postingClass, int runNo, Iterator<MapEmittedPostingList> _postingiterator, String _term, int numFields) throws Exception
postingClass
- is the name of the class to use to read the postingsrunNo
- is the number of the run_postingiterator
- is the iterator of reduce input data that we are going to loop through_term
- is the term that this iterator is operating onException
public boolean hasNext()
hasNext
in interface Iterator<PostingInRun>
hasNext
in class RunIterator
public PostingInRun next()
next
in interface Iterator<PostingInRun>
next
in class RunIterator
public String getMapNo()
public int getSplitNo()
Terrier 4.0. Copyright © 2004-2014 University of Glasgow