org.apache.nutch.indexer
Class DeleteDuplicates.InputFormat

java.lang.Object
  extended by org.apache.hadoop.mapred.InputFormatBase
      extended by org.apache.nutch.indexer.DeleteDuplicates.InputFormat
All Implemented Interfaces:
InputFormat
Enclosing class:
DeleteDuplicates

public static class DeleteDuplicates.InputFormat
extends InputFormatBase


Nested Class Summary
 class DeleteDuplicates.InputFormat.DDRecordReader
           
 
Field Summary
 
Fields inherited from class org.apache.hadoop.mapred.InputFormatBase
LOG
 
Constructor Summary
DeleteDuplicates.InputFormat()
           
 
Method Summary
 RecordReader getRecordReader(InputSplit split, JobConf job, Reporter reporter)
          Return each index as a split.
 InputSplit[] getSplits(JobConf job, int numSplits)
          Return each index as a split.
 
Methods inherited from class org.apache.hadoop.mapred.InputFormatBase
isSplitable, listPaths, setMinSplitSize, validateInput
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

DeleteDuplicates.InputFormat

public DeleteDuplicates.InputFormat()
Method Detail

getSplits

public InputSplit[] getSplits(JobConf job,
                              int numSplits)
                       throws IOException
Return each index as a split.

Specified by:
getSplits in interface InputFormat
Overrides:
getSplits in class InputFormatBase
Throws:
IOException

getRecordReader

public RecordReader getRecordReader(InputSplit split,
                                    JobConf job,
                                    Reporter reporter)
                             throws IOException
Return each index as a split.

Specified by:
getRecordReader in interface InputFormat
Specified by:
getRecordReader in class InputFormatBase
Throws:
IOException


Copyright © 2006 The Apache Software Foundation