de.hpi.fgis.voidgen.hadoop.closure
Class Step1Partitioner

java.lang.Object
  extended by org.apache.hadoop.mapreduce.Partitioner<K,V>
      extended by org.apache.hadoop.mapreduce.lib.partition.HashPartitioner<Step1Pair,ClusterId>
          extended by de.hpi.fgis.voidgen.hadoop.closure.Step1Partitioner

public class Step1Partitioner
extends org.apache.hadoop.mapreduce.lib.partition.HashPartitioner<Step1Pair,ClusterId>

Provides distributing keys consisting of real key and value to different reducers only depended on the real key.

Author:
Johannes Gosda, Hasso Plattner Institute at University of Potsdam, Germany

Constructor Summary
Step1Partitioner()
           
 
Method Summary
 int getPartition(Step1Pair key, ClusterId value, int numReduceTasks)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

Step1Partitioner

public Step1Partitioner()
Method Detail

getPartition

public int getPartition(Step1Pair key,
                        ClusterId value,
                        int numReduceTasks)
Overrides:
getPartition in class org.apache.hadoop.mapreduce.lib.partition.HashPartitioner<Step1Pair,ClusterId>