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

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

public class Step2Partitioner
extends org.apache.hadoop.mapreduce.lib.partition.HashPartitioner<Step2Pair,NodeXOrId>

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
Step2Partitioner()
           
 
Method Summary
 int getPartition(Step2Pair key, NodeXOrId value, int numReduceTasks)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

Step2Partitioner

public Step2Partitioner()
Method Detail

getPartition

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