public static class SumReducer.DoubleSumReducer
extends org.apache.hadoop.mapred.MapReduceBase
implements org.apache.hadoop.mapred.Reducer<org.apache.hadoop.io.Text,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.Text,org.apache.hadoop.io.DoubleWritable>
Modifier and Type | Class and Description |
---|---|
static class |
SumReducer.DoubleSumReducer.FloatSumReducer |
Constructor and Description |
---|
SumReducer.DoubleSumReducer() |
Modifier and Type | Method and Description |
---|---|
void |
reduce(org.apache.hadoop.io.Text key,
java.util.Iterator<org.apache.hadoop.io.DoubleWritable> values,
org.apache.hadoop.mapred.OutputCollector<org.apache.hadoop.io.Text,org.apache.hadoop.io.DoubleWritable> output,
org.apache.hadoop.mapred.Reporter reporter) |
public void reduce(org.apache.hadoop.io.Text key, java.util.Iterator<org.apache.hadoop.io.DoubleWritable> values, org.apache.hadoop.mapred.OutputCollector<org.apache.hadoop.io.Text,org.apache.hadoop.io.DoubleWritable> output, org.apache.hadoop.mapred.Reporter reporter) throws java.io.IOException
reduce
in interface org.apache.hadoop.mapred.Reducer<org.apache.hadoop.io.Text,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.Text,org.apache.hadoop.io.DoubleWritable>
java.io.IOException