pegasus.mapreduce.common.prepartitioning

Class PrepartitioningPartitioner

java.lang.Object

org.apache.hadoop.mapreduce.Partitioner<org.apache.hadoop.io.LongWritable,java.lang.Object>

pegasus.mapreduce.common.prepartitioning.PrepartitioningPartitioner

public class PrepartitioningPartitioner
extends org.apache.hadoop.mapreduce.Partitioner<org.apache.hadoop.io.LongWritable,java.lang.Object>

Constructor Summary

Constructors

Constructor and Description
PrepartitioningPartitioner()

Method Summary

Modifier and Type	Method and Description
int	getPartition(org.apache.hadoop.io.LongWritable vertex, java.lang.Object ignored, int numPartitions)

Methods inherited from class java.lang.Object

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

Constructor Detail

PrepartitioningPartitioner

public PrepartitioningPartitioner()

Method Detail

getPartition

public int getPartition(org.apache.hadoop.io.LongWritable vertex,
                        java.lang.Object ignored,
                        int numPartitions)

Specified by:

getPartition in class org.apache.hadoop.mapreduce.Partitioner<org.apache.hadoop.io.LongWritable,java.lang.Object>