org.apache.nutch.indexer
Class DeleteDuplicates.InputFormat.DDRecordReader

java.lang.Object
  extended by org.apache.nutch.indexer.DeleteDuplicates.InputFormat.DDRecordReader
All Implemented Interfaces:
org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.Text,DeleteDuplicates.IndexDoc>
Enclosing class:
DeleteDuplicates.InputFormat

public class DeleteDuplicates.InputFormat.DDRecordReader
extends Object
implements org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.Text,DeleteDuplicates.IndexDoc>


Constructor Summary
DeleteDuplicates.InputFormat.DDRecordReader(org.apache.hadoop.mapred.FileSplit split, org.apache.hadoop.mapred.JobConf job, org.apache.hadoop.io.Text index)
           
 
Method Summary
 void close()
           
 org.apache.hadoop.io.Text createKey()
           
 DeleteDuplicates.IndexDoc createValue()
           
 long getPos()
           
 float getProgress()
           
 boolean next(org.apache.hadoop.io.Text key, DeleteDuplicates.IndexDoc indexDoc)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

DeleteDuplicates.InputFormat.DDRecordReader

public DeleteDuplicates.InputFormat.DDRecordReader(org.apache.hadoop.mapred.FileSplit split,
                                                   org.apache.hadoop.mapred.JobConf job,
                                                   org.apache.hadoop.io.Text index)
                                            throws IOException
Throws:
IOException
Method Detail

next

public boolean next(org.apache.hadoop.io.Text key,
                    DeleteDuplicates.IndexDoc indexDoc)
             throws IOException
Specified by:
next in interface org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.Text,DeleteDuplicates.IndexDoc>
Throws:
IOException

getPos

public long getPos()
            throws IOException
Specified by:
getPos in interface org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.Text,DeleteDuplicates.IndexDoc>
Throws:
IOException

close

public void close()
           throws IOException
Specified by:
close in interface org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.Text,DeleteDuplicates.IndexDoc>
Throws:
IOException

createKey

public org.apache.hadoop.io.Text createKey()
Specified by:
createKey in interface org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.Text,DeleteDuplicates.IndexDoc>

createValue

public DeleteDuplicates.IndexDoc createValue()
Specified by:
createValue in interface org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.Text,DeleteDuplicates.IndexDoc>

getProgress

public float getProgress()
                  throws IOException
Specified by:
getProgress in interface org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.Text,DeleteDuplicates.IndexDoc>
Throws:
IOException


Copyright © 2006 The Apache Software Foundation