de.hpi.fgis.voidgen.hadoop.tasks.joining
Class JoinPartitioner

java.lang.Object
  extended by de.hpi.fgis.voidgen.hadoop.tasks.joining.JoinPartitioner
All Implemented Interfaces:
org.apache.hadoop.mapred.JobConfigurable, org.apache.hadoop.mapred.Partitioner<StringIntPair,RDFQuadruple>

public class JoinPartitioner
extends java.lang.Object
implements org.apache.hadoop.mapred.Partitioner<StringIntPair,RDFQuadruple>

The partitioner for partitioning pairs only depending on the left part of the pair.

Author:
Dandy Fenz, Hasso Plattner Institute at University of Potsdam, Germany, Matthias Pohl, Hasso Plattner Institute at University of Potsdam, Germany, Johannes Gosda, Hasso Plattner Institute at University of Potsdam, Germany

Constructor Summary
JoinPartitioner()
           
 
Method Summary
 void configure(org.apache.hadoop.mapred.JobConf arg0)
           
 int getPartition(StringIntPair key, RDFQuadruple value, int numPartitions)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

JoinPartitioner

public JoinPartitioner()
Method Detail

getPartition

public int getPartition(StringIntPair key,
                        RDFQuadruple value,
                        int numPartitions)
Specified by:
getPartition in interface org.apache.hadoop.mapred.Partitioner<StringIntPair,RDFQuadruple>

configure

public void configure(org.apache.hadoop.mapred.JobConf arg0)
Specified by:
configure in interface org.apache.hadoop.mapred.JobConfigurable