public static class DeduplicationJob.DedupReducer extends Object implements Reducer<BytesWritable,CrawlDatum,Text,CrawlDatum>
Constructor and Description |
---|
DeduplicationJob.DedupReducer() |
Modifier and Type | Method and Description |
---|---|
void |
close() |
void |
configure(JobConf arg0) |
void |
reduce(BytesWritable key,
Iterator<CrawlDatum> values,
OutputCollector<Text,CrawlDatum> output,
Reporter reporter) |
public void reduce(BytesWritable key, Iterator<CrawlDatum> values, OutputCollector<Text,CrawlDatum> output, Reporter reporter) throws IOException
reduce
in interface Reducer<BytesWritable,CrawlDatum,Text,CrawlDatum>
IOException
public void configure(JobConf arg0)
configure
in interface JobConfigurable
public void close() throws IOException
close
in interface Closeable
close
in interface AutoCloseable
IOException
Copyright © 2015 The Apache Software Foundation