public static class DistSum.ReduceSide.IndexPartitioner extends Partitioner<IntWritable,SummationWritable>
Constructor and Description |
---|
DistSum.ReduceSide.IndexPartitioner() |
Modifier and Type | Method and Description |
---|---|
int |
getPartition(IntWritable index,
SummationWritable value,
int numPartitions)
Return the index as the partition.
|
public int getPartition(IntWritable index, SummationWritable value, int numPartitions)
getPartition
in class Partitioner<IntWritable,SummationWritable>
index
- the key to be partioned.value
- the entry value.numPartitions
- the total number of partitions.key
.Copyright © 2013 Apache Software Foundation. All rights reserved.