public static class SuggestService.SuggestServiceReducer<K,V> extends org.apache.hadoop.mapred.MapReduceBase implements org.apache.hadoop.mapred.Reducer<org.apache.hadoop.io.Text,RecordInfo,org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.Text>
| Constructor and Description |
|---|
SuggestServiceReducer() |
| Modifier and Type | Method and Description |
|---|---|
void |
configure(org.apache.hadoop.mapred.JobConf conf) |
void |
reduce(org.apache.hadoop.io.Text key, java.util.Iterator<RecordInfo> values, org.apache.hadoop.mapred.OutputCollector<org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.Text> output, org.apache.hadoop.mapred.Reporter reporter) |
public void configure(org.apache.hadoop.mapred.JobConf conf)
configure in interface org.apache.hadoop.mapred.JobConfigurableconfigure in class org.apache.hadoop.mapred.MapReduceBase
public void reduce(org.apache.hadoop.io.Text key,
java.util.Iterator<RecordInfo> values,
org.apache.hadoop.mapred.OutputCollector<org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.Text> output,
org.apache.hadoop.mapred.Reporter reporter)
throws java.io.IOException
reduce in interface org.apache.hadoop.mapred.Reducer<org.apache.hadoop.io.Text,RecordInfo,org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.Text>java.io.IOException