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

java.lang.Object
  extended by org.apache.hadoop.mapred.MapReduceBase
      extended by de.hpi.fgis.voidgen.hadoop.tasks.joining.Join2QuadrupleInputMapper
All Implemented Interfaces:
java.io.Closeable, org.apache.hadoop.mapred.JobConfigurable, org.apache.hadoop.mapred.Mapper<StringIntPair,RDFQuadruple,StringIntPair,RDFQuadruple>

public class Join2QuadrupleInputMapper
extends org.apache.hadoop.mapred.MapReduceBase
implements org.apache.hadoop.mapred.Mapper<StringIntPair,RDFQuadruple,StringIntPair,RDFQuadruple>

Identity mapper for reading output of join step 1 and pipes the quadruples, annotated with the subject cluster, to the reducer.

Input

Output is equal to input.

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
Join2QuadrupleInputMapper()
           
 
Method Summary
 void map(StringIntPair key, RDFQuadruple value, org.apache.hadoop.mapred.OutputCollector<StringIntPair,RDFQuadruple> output, org.apache.hadoop.mapred.Reporter reporter)
           
 
Methods inherited from class org.apache.hadoop.mapred.MapReduceBase
close, configure
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 
Methods inherited from interface org.apache.hadoop.mapred.JobConfigurable
configure
 
Methods inherited from interface java.io.Closeable
close
 

Constructor Detail

Join2QuadrupleInputMapper

public Join2QuadrupleInputMapper()
Method Detail

map

public void map(StringIntPair key,
                RDFQuadruple value,
                org.apache.hadoop.mapred.OutputCollector<StringIntPair,RDFQuadruple> output,
                org.apache.hadoop.mapred.Reporter reporter)
         throws java.io.IOException
Specified by:
map in interface org.apache.hadoop.mapred.Mapper<StringIntPair,RDFQuadruple,StringIntPair,RDFQuadruple>
Throws:
java.io.IOException