edu.umd.cloud9.example.pagerank
Class RangePartitioner

java.lang.Object
  org.apache.hadoop.mapreduce.Partitioner<IntWritable,Writable>
      edu.umd.cloud9.example.pagerank.RangePartitioner

All Implemented Interfaces:

Configurable

public class RangePartitioner
extends Partitioner<IntWritable,Writable>
implements Configurable

Ranger partitioner. In the context of graph algorithms, ensures that consecutive node ids are blocked together.

Author:

Jimmy Lin, Michael Schatz

Constructor Summary

RangePartitioner()

Method Summary

Configuration	getConf()
int	getPartition(IntWritable key, Writable value, int numReduceTasks)
void	setConf(Configuration conf)

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RangePartitioner

public RangePartitioner()

Method Detail

getPartition

public int getPartition(IntWritable key,
                        Writable value,
                        int numReduceTasks)

Specified by:

getPartition in class Partitioner<IntWritable,Writable>

getConf

public Configuration getConf()

Specified by:

getConf in interface Configurable

setConf

public void setConf(Configuration conf)

Specified by:

setConf in interface Configurable