public static class DistSum.ReduceSide.PartitionMapper extends org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.io.NullWritable,SummationWritable,org.apache.hadoop.io.IntWritable,SummationWritable>
Constructor and Description |
---|
DistSum.ReduceSide.PartitionMapper() |
Modifier and Type | Method and Description |
---|---|
protected void |
map(org.apache.hadoop.io.NullWritable nw,
SummationWritable sigma,
org.apache.hadoop.mapreduce.Mapper.Context context)
Partitions sigma into parts
|
protected void map(org.apache.hadoop.io.NullWritable nw, SummationWritable sigma, org.apache.hadoop.mapreduce.Mapper.Context context) throws IOException, InterruptedException
map
in class org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.io.NullWritable,SummationWritable,org.apache.hadoop.io.IntWritable,SummationWritable>
IOException
InterruptedException
Copyright © 2015 Apache Software Foundation. All Rights Reserved.