public static class DeduplicationJob.DedupReducer extends java.lang.Object implements Reducer<BytesWritable,CrawlDatum,Text,CrawlDatum>
| Constructor and Description |
|---|
DedupReducer() |
| Modifier and Type | Method and Description |
|---|---|
void |
close() |
void |
configure(JobConf arg0) |
void |
reduce(BytesWritable key,
java.util.Iterator<CrawlDatum> values,
OutputCollector<Text,CrawlDatum> output,
Reporter reporter) |
public void configure(JobConf arg0)
configure in interface JobConfigurablepublic void reduce(BytesWritable key, java.util.Iterator<CrawlDatum> values, OutputCollector<Text,CrawlDatum> output, Reporter reporter) throws java.io.IOException
reduce in interface Reducer<BytesWritable,CrawlDatum,Text,CrawlDatum>java.io.IOExceptionpublic void close()
throws java.io.IOException
close in interface java.io.Closeableclose in interface java.lang.AutoCloseablejava.io.IOExceptionCopyright © 2017 The Apache Software Foundation