public static class DistSum.ReduceSide.IndexPartitioner extends org.apache.hadoop.mapreduce.Partitioner<org.apache.hadoop.io.IntWritable,SummationWritable>
Constructor and Description |
---|
DistSum.ReduceSide.IndexPartitioner() |
Modifier and Type | Method and Description |
---|---|
int |
getPartition(org.apache.hadoop.io.IntWritable index,
SummationWritable value,
int numPartitions)
Return the index as the partition.
|
public int getPartition(org.apache.hadoop.io.IntWritable index, SummationWritable value, int numPartitions)
getPartition
in class org.apache.hadoop.mapreduce.Partitioner<org.apache.hadoop.io.IntWritable,SummationWritable>
Copyright © 2015 Apache Software Foundation. All Rights Reserved.