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

java.lang.Object
  org.apache.nutch.indexer.DeleteDuplicates.InputFormat.DDRecordReader

All Implemented Interfaces:

RecordReader<Text,DeleteDuplicates.IndexDoc>

Enclosing class:

DeleteDuplicates.InputFormat

public class DeleteDuplicates.InputFormat.DDRecordReader
extends Object
implements RecordReader<Text,DeleteDuplicates.IndexDoc>

Constructor Summary

DeleteDuplicates.InputFormat.DDRecordReader(FileSplit split, JobConf job, Text index)

Method Summary

void	close()
Text	createKey()
DeleteDuplicates.IndexDoc	createValue()
long	getPos()
float	getProgress()
boolean	next(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(FileSplit split,
                                                   JobConf job,
                                                   Text index)
                                            throws IOException

Throws:

IOException

Method Detail

next

public boolean next(Text key,
                    DeleteDuplicates.IndexDoc indexDoc)
             throws IOException

Specified by:

next in interface RecordReader<Text,DeleteDuplicates.IndexDoc>

Throws:

IOException

getPos

public long getPos()
            throws IOException

Specified by:

getPos in interface RecordReader<Text,DeleteDuplicates.IndexDoc>

Throws:

IOException

close

public void close()
           throws IOException

Specified by:

close in interface RecordReader<Text,DeleteDuplicates.IndexDoc>

Throws:

IOException

createKey

public Text createKey()

Specified by:

createKey in interface RecordReader<Text,DeleteDuplicates.IndexDoc>

createValue

public DeleteDuplicates.IndexDoc createValue()

Specified by:

createValue in interface RecordReader<Text,DeleteDuplicates.IndexDoc>

getProgress

public float getProgress()
                  throws IOException

Specified by:

getProgress in interface RecordReader<Text,DeleteDuplicates.IndexDoc>

Throws:

IOException